`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)[源代码]¶

基类: airflow.models.BaseOperator

将文件从源复制到目标。

如果需要，这将把文件从源头流式传输到目的地，因此不需要将其放入内存中。

参数

src (str | airflow.io.path.ObjectStoragePath) – 源文件路径或 ObjectStoragePath 对象。
dst (str | airflow.io.path.ObjectStoragePath) – 目标文件路径或 ObjectStoragePath 对象。
source_conn_id (str | None) – 可选的源连接 ID。
dest_conn_id (str | None) – 可选的目标连接 ID。

另请参阅

有关如何使用此运算符的更多信息，请查看以下指南: 传输文件

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

execute(context)[源代码]¶

在创建运算符时派生。

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

有关更多上下文，请参阅 get_template_context。

get_openlineage_facets_on_start()[源代码]¶

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

模块内容¶

类¶

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