airflow.providers.amazon.aws.transfers.exasol_to_s3¶
将数据从 Exasol 数据库传输到 S3 存储桶。
模块内容¶
类¶
将数据从 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_ext: collections.abc.Sequence[str] = ('.sql',)[source]¶