airflow.providers.alibaba.cloud.operators.oss¶

此模块包含阿里云 OSS 操作符。

类¶

`OSSCreateBucketOperator`	此操作符用于创建 OSS Bucket。
`OSSDeleteBucketOperator`	此操作符用于删除 OSS Bucket。
`OSSUploadObjectOperator`	此操作符用于上传类文件对象。
`OSSDownloadObjectOperator`	此操作符用于下载 OSS 对象。
`OSSDeleteBatchObjectOperator`	此操作符用于删除 OSS 对象。
`OSSDeleteObjectOperator`	此操作符用于删除单个 OSS 对象。

模块内容¶

class airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator(region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于创建 OSS Bucket。

参数:

region (str) – 您想要创建 Bucket 的 OSS 区域
bucket_name (str | None) – 您想要创建的 Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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

class airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator(region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于删除 OSS Bucket。

参数:

region (str) – 您想要创建 Bucket 的 OSS 区域
bucket_name (str | None) – 您想要删除的 Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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

class airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator(key, file, region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于上传类文件对象。

参数:

key (str) – 对象在 OSS 中的路径
file (str) – 本地待上传的文件。
region (str) – 您想要创建 Bucket 的 OSS 区域
bucket_name (str | None) – 您想要创建的 Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

key[source]¶

file[source]¶

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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

class airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator(key, file, region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于下载 OSS 对象。

参数:

key (str) – 要下载的对象键。
local_file – 本地保存路径和文件名。
region (str) – OSS 区域
bucket_name (str | None) – OSS Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

key[source]¶

file[source]¶

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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

class airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator(keys, region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于删除 OSS 对象。

参数:

key – 要删除的对象键列表。
region (str) – OSS 区域
bucket_name (str | None) – OSS Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

keys[source]¶

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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

class airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator(key, region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

此操作符用于删除单个 OSS 对象。

参数:

key (str) – 要删除的对象键。
region (str) – OSS 区域
bucket_name (str | None) – OSS Bucket 名称
oss_conn_id (str) – 用于 OSS 凭证的 Airflow 连接。

key[source]¶

oss_conn_id = 'oss_default'[source]¶

region[source]¶

bucket_name = None[source]¶

execute(context)[source]¶

在创建算子时派生。

执行任务的主要方法。Context 是与渲染 jinja 模板时使用的相同字典。

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