airflow.providers.exasol.hooks.exasol

属性

T

类

ExasolHook

与 Exasol 交互。

函数

exasol_fetch_all_handler(statement)

exasol_fetch_one_handler(statement)

模块内容

airflow.providers.exasol.hooks.exasol.T[源]
class airflow.providers.exasol.hooks.exasol.ExasolHook(*args, **kwargs)[源]

基类：airflow.providers.common.sql.hooks.sql.DbApiHook

与 Exasol 交互。

您可以在连接的额外字段中指定 pyexasol 的 compression、encryption、json_lib 和 client_name 参数，例如 {"compression": True, "json_lib": "rapidjson", etc}。

有关更多详细信息，请参阅pyexasol 参考。

conn_name_attr = 'exasol_conn_id'[源]
default_conn_name = 'exasol_default'[源]
conn_type = 'exasol'[源]
hook_name = 'Exasol'[源]
supports_autocommit = True[源]
schema[源]
get_conn()[源]

返回一个连接对象。

get_pandas_df(sql, parameters=None, **kwargs)[源]

执行 SQL 并返回 Pandas 数据框。

参数：

其他关键字参数都会转发给 pyexasol.ExaConnection.export_to_pandas。

get_records(sql, parameters=None)[源]

执行 SQL 并返回一组记录。

参数：
get_first(sql, parameters=None)[源]

执行 SQL 并返回第一行结果。

参数：
export_to_file(filename, query_or_table, query_params=None, export_params=None)[源]

将数据导出到文件。

参数：

  • filename (str) – 要导出数据的文件的路径

  • query_or_table (str) – 要执行的 sql 语句或要导出的表名

  • query_params (dict | None) – 传递给 ExaConnection 的底层 export_to_file 方法的查询参数。

  • export_params (dict | None) – 传递给 ExaConnection 的底层 export_to_file 方法的额外参数。

static get_description(statement)[源]

获取描述；复制自 DB2-API wrapper 的实现。

更多信息请参阅 https://github.com/exasol/pyexasol/blob/master/docs/DBAPI_COMPAT.md#db-api-20-wrapper

参数：

statement (pyexasol.ExaStatement) – Exasol 语句

返回：

t 的描述序列

返回类型：

collections.abc.Sequence[collections.abc.Sequence]

run(sql: str | collections.abc.Iterable[str], autocommit: bool = ..., parameters: collections.abc.Iterable | collections.abc.Mapping[str, Any] | None = ..., handler: None = ..., split_statements: bool = ..., return_last: bool = ...) → None[源]
run(sql: str | collections.abc.Iterable[str], autocommit: bool = ..., parameters: collections.abc.Iterable | collections.abc.Mapping[str, Any] | None = ..., handler: Callable[[Any], T] = ..., split_statements: bool = ..., return_last: bool = ...) → tuple | list[tuple] | list[list[tuple] | tuple] | None

运行一个或一组命令。

向 SQL 参数传递 SQL 语句列表，以便按顺序执行它们。

参数：

  • sql – 要执行的 sql 语句（字符串）或要执行的 sql 语句列表

  • autocommit – 在执行查询之前，连接的 autocommit 设置要设置为的值。

  • parameters – 用于渲染 SQL 查询的参数。

  • handler – 结果处理程序，每个语句的结果都会调用它。

  • split_statements – 是否将单个 SQL 字符串拆分成多个语句并分别运行

  • return_last – 对于拆分后的语句，是仅返回最后一个结果还是返回所有结果

返回：

如果提供了 handler，则仅返回最后一个 SQL 表达式的结果。

set_autocommit(conn, autocommit)[源]

在连接上设置 autocommit 标志。

参数：

  • conn – 要设置 autocommit 设置的连接。

  • autocommit (bool) – 要设置的 autocommit 设置。

get_autocommit(conn)[源]

获取提供的连接的 autocommit 设置。

参数：

conn – 要从中获取 autocommit 设置的连接。

返回：

连接的 autocommit 设置。如果连接上 autocommit 设置为 True，则为 True。如果未设置、设置为 False 或连接不支持自动提交，则为 False。

返回类型：

bool

airflow.providers.exasol.hooks.exasol.exasol_fetch_all_handler(statement)[源]
airflow.providers.exasol.hooks.exasol.exasol_fetch_one_handler(statement)[源]

此条目有帮助吗？