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。