airflow.providers.common.io.operators.file_transfer¶

類¶

FileTransferOperator

將檔案從源複製到目標。

模組內容¶

class airflow.providers.common.io.operators.file_transfer.FileTransferOperator(*, src, dst, source_conn_id=None, dest_conn_id=None, overwrite=False, **kwargs)[source]¶

基礎：airflow.sdk.bases.operator.BaseOperator

將檔案從源複製到目標。

如果需要，這會從源流式傳輸檔案到目標，因此它不需要佔用記憶體。

引數:

src (str | airflow.sdk.ObjectStoragePath) – 原始檔路徑或 ObjectStoragePath 物件。
dst (str | airflow.sdk.ObjectStoragePath) – 目標檔案路徑或 ObjectStoragePath 物件。
source_conn_id (str | None) – 可選的源連線 ID。
dest_conn_id (str | None) – 可選的目標連線 ID。

另請參閱

關於如何使用此運算子的更多資訊，請參閱指南：傳輸檔案

template_fields: collections.abc.Sequence[str] = ('src', 'dst')[source]¶

src[source]¶

dst[source]¶

source_conn_id = None[source]¶

dst_conn_id = None[source]¶

overwrite = False[source]¶

execute(context)[source]¶

建立運算子時派生。

執行任務的主要方法。上下文與渲染 Jinja 模板時使用的字典相同。

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

get_openlineage_facets_on_start()[source]¶