SQLAlchemy
flytekitplugins-sqlalchemy
SQLAlchemy is the Python SQL toolkit and Object Relational Mapper that gives application developers the full power and flexibility of SQL. Flyte provides an easy-to-use interface to utilize SQLAlchemy to connect to various SQL Databases.
pip install flytekitplugins-sqlalchemyQuick Start(example, may need adjustment)
See full examplespip install flytekitplugins-sqlalchemy
from flytekit import task, workflow
from flytekitplugins.sqlalchemy import SQLAlchemyConfig, SQLAlchemyDefaultImages, SQLAlchemyTask
@task(task_config=SQLAlchemyTask(...))
def my_task() -> None:
...
@workflow
def my_workflow() -> None:
my_task()Available Imports (3)
Use this configuration to configure task.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.sqlalchemy import SQLAlchemyConfig
Default images for the sqlalchemy flytekit plugin.
from flytekitplugins.sqlalchemy import SQLAlchemyDefaultImages
Makes it possible to run client side SQLAlchemy queries that optionally return a FlyteSchema object.
extends PythonCustomizedContainerTask — a flyte task that can be used in workflows
from flytekitplugins.sqlalchemy import SQLAlchemyTask
Dependencies
Related Plugins
Bigquery
BigQuery enables us to build data-intensive applications without operational burden. Flyte backend can be connected with the BigQuery service. Once enabled, it can allow you to query a BigQuery table.
BigQuery
This plugin provides BigQuery integration for Flyte, enabling you to run BigQuery queries as Flyte tasks.
Dolt
The DoltTable plugin is a wrapper that uses Dolt to move data between pandas.DataFrame’s at execution time and database tables at rest.
DuckDB
Run analytical workloads with ease using DuckDB.
