airflow.providers.amazon.aws.transfers.local_to_s3¶

類¶

LocalFilesystemToS3Operator

將檔案從本地檔案系統上傳到 Amazon S3。

模組內容¶

class airflow.providers.amazon.aws.transfers.local_to_s3.LocalFilesystemToS3Operator(*, filename, dest_key, dest_bucket=None, aws_conn_id='aws_default', verify=None, replace=False, encrypt=False, gzip=False, acl_policy=None, **kwargs)[source]¶

基礎： airflow.models.BaseOperator

將檔案從本地檔案系統上傳到 Amazon S3。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：本地到 Amazon S3 傳輸運算子

引數：

filename (str) – 本地檔案的路徑。路徑可以是絕對路徑（例如 /path/to/file.ext），也可以是相對路徑（例如 ../../foo//.csv）。(模板化)
dest_key (str) –
要複製到的物件的鍵。(模板化)

可以是完整的 s3:// 風格 URL，也可以是相對於根級別的路徑。

當指定為完整的 s3:// URL 時，請省略 dest_bucket。
dest_bucket (str | None) – 物件複製到的 S3 儲存桶的名稱。(模板化)
aws_conn_id (str | None) – 要使用的 S3 連線的連線 ID
verify (str | bool | None) –
是否驗證 S3 連線的 SSL 證書。預設情況下會驗證 SSL 證書。

您可以提供以下值：
- False：不驗證 SSL 證書。SSL 仍將使用，
  但 SSL 證書將不被驗證。
- path/to/cert/bundle.pem：CA 證書包的檔名。
  如果您想使用與 botocore 使用的不同 CA 證書包，可以指定此引數。
replace (bool) – 一個標誌，決定是否覆蓋已存在的鍵。如果 replace 為 False 且鍵已存在，則會引發錯誤。
encrypt (bool) – 如果為 True，檔案將在伺服器端由 S3 加密，並以加密形式儲存在 S3 中。
gzip (bool) – 如果為 True，檔案將在本地被壓縮
acl_policy (str | None) – 指定上傳到 S3 儲存桶的檔案的 canned ACL 策略的字串。

template_fields: collections.abc.Sequence[str] = ('filename', 'dest_key', 'dest_bucket')[source]¶

filename[source]¶

dest_key[source]¶

dest_bucket = None[source]¶

aws_conn_id = 'aws_default'[source]¶

verify = None[source]¶

replace =False[source]¶

encrypt =False[source]¶

gzip =False[source]¶

acl_policy =None[source]¶

execute(context)[source]¶

建立運算子時派生。

上下文與渲染 Jinja 模板時使用的字典相同。

有關更多上下文資訊，請參閱 get_template_context。