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

此模块包含阿里云 OSS operators。

类¶

`OSSCreateBucketOperator`	该 operator 用于创建 OSS bucket。
`OSSDeleteBucketOperator`	该 operator 用于删除 OSS bucket。
`OSSUploadObjectOperator`	该 operator 用于上传文件类对象。
`OSSDownloadObjectOperator`	该 operator 用于下载 OSS 对象。
`OSSDeleteBatchObjectOperator`	该 operator 用于批量删除 OSS 对象。
`OSSDeleteObjectOperator`	该 operator 用于删除 OSS 对象。

模块内容¶

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

基类: airflow.models.BaseOperator

该 operator 用于创建 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]¶

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。

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

基类: airflow.models.BaseOperator

该 operator 用于删除 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]¶

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。

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

基类: airflow.models.BaseOperator

该 operator 用于上传文件类对象。

参数:

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

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。

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

基类: airflow.models.BaseOperator

该 operator 用于下载 OSS 对象。

参数:

key (str) – 要下载对象的 key。
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]¶

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。

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

基类: airflow.models.BaseOperator

该 operator 用于批量删除 OSS 对象。

参数:

key – 要删除对象的 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]¶

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。

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

基类: airflow.models.BaseOperator

该 operator 用于删除 OSS 对象。

参数:

key (str) – 要删除对象的 key。
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]¶

创建 Operator 时派生。

Context 与渲染 Jinja 模板时使用的字典相同。

请参阅 get_template_context 以获取更多 context 信息。