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

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

模块内容¶

类¶

`OSSCreateBucketOperator`	该操作符创建 OSS 存储桶。
`OSSDeleteBucketOperator`	该操作符删除 OSS 存储桶。
`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)[源代码]¶

基类: airflow.models.BaseOperator

该操作符创建 OSS 存储桶。

参数

region (str) – 您要创建存储桶的 OSS 区域
bucket_name (str | None) – 这是您要创建的存储桶名称
oss_conn_id (str) – 用于 OSS 凭据的 Airflow 连接。

execute(context)[源代码]¶

创建操作符时派生。

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

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

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

基类: airflow.models.BaseOperator

该操作符删除 OSS 存储桶。

参数

region (str) – 您要创建存储桶的 OSS 区域
bucket_name (str | None) – 这是您要删除的存储桶名称
oss_conn_id (str) – 用于 OSS 凭据的 Airflow 连接。

execute(context)[源代码]¶

创建操作符时派生。

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

基类: airflow.models.BaseOperator

该操作符上传类文件对象。

参数

key (str) – 对象的 OSS 路径
file (str) – 要上传的本地文件。
region (str) – 您要创建存储桶的 OSS 区域
bucket_name (str | None) – 这是您要创建的存储桶名称
oss_conn_id (str) – 用于 OSS 凭据的 Airflow 连接。

execute(context)[源代码]¶

创建操作符时派生。

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

基类: airflow.models.BaseOperator

该操作符下载 OSS 对象。

参数

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

execute(context)[源代码]¶

创建操作符时派生。

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

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

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

基类: airflow.models.BaseOperator

该操作符删除 OSS 对象。

参数

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

execute(context)[源代码]¶

创建操作符时派生。

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

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

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

基类: airflow.models.BaseOperator

该操作符删除 OSS 对象。

参数

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

执行(上下文)[源代码]¶

创建操作符时派生。

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

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

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

模块内容¶

类¶

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