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]¶