airflow.providers.amazon.aws.transfers.exasol_to_s3¶

将数据从 Exasol 数据库传输到 S3 存储桶。

类¶

ExasolToS3Operator

将数据从 Exasol 数据库导出到 AWS S3 存储桶。

模块内容¶

class airflow.providers.amazon.aws.transfers.exasol_to_s3.ExasolToS3Operator(*, query_or_table, key, bucket_name=None, replace=False, encrypt=False, gzip=False, acl_policy=None, query_params=None, export_params=None, exasol_conn_id='exasol_default', aws_conn_id='aws_default', **kwargs)[source]¶

基类：airflow.models.BaseOperator

将数据从 Exasol 数据库导出到 AWS S3 存储桶。

参数：

query_or_table (str) – 要执行的 SQL 语句或要导出的表名
key (str) – 指向文件的 S3 键
bucket_name (str | None) – 用于存储文件的存储桶名称
replace (bool) – 一个标志，用于确定是否覆盖已存在的键。如果 replace 为 False 且键已存在，将引发错误。
encrypt (bool) – 如果为 True，文件将在 S3 服务器端加密，并在 S3 中处于静止状态时以加密形式存储。
gzip (bool) – 如果为 True，文件将在本地压缩
acl_policy (str | None) – 指定上传到 S3 存储桶的文件的预设 ACL 策略的字符串。
query_params (dict | None) – 传递给 ExaConnection 底层 export_to_file 方法的查询参数。
export_params (dict | None) – 传递给 ExaConnection 底层 export_to_file 方法的额外参数。

template_fields: collections.abc.Sequence[str] = ('query_or_table', 'key', 'bucket_name', 'query_params', 'export_params')[source]¶

template_fields_renderers[source]¶

template_ext: collections.abc.Sequence[str] = ('.sql',)[source]¶

ui_color = '#ededed'[source]¶

query_or_table[source]¶

key[source]¶

bucket_name = None[source]¶

replace = False[source]¶

encrypt = False[source]¶

gzip = False[source]¶

acl_policy = None[source]¶

query_params = None[source]¶

export_params = None[source]¶

exasol_conn_id = 'exasol_default'[source]¶

aws_conn_id = 'aws_default'[source]¶

execute(context)[source]¶

创建操作符时派生而来。

Context 是与渲染 Jinja 模板时使用的字典相同的字典。

有关更多上下文信息，请参阅 get_template_context。