oss.rst

Alibaba Cloud OSS Operators

Overview

Airflow to Alibaba Cloud Object Storage Service (OSS) integration provides several operators to create and interact with OSS buckets.

• :class:`~airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator`
• :class:`~airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator`

Create and Delete Alibaba Cloud OSS Buckets

Purpose

This example dag uses OSSCreateBucketOperator and OSSDeleteBucketOperator to create a new OSS bucket with a given bucket name then delete it.

Defining tasks

In the following code we create a new bucket and then delete the bucket.

.. exampleinclude:: /../../tests/system/providers/alibaba/example_oss_bucket.py
    :language: python
    :start-after: [START howto_operator_oss_bucket]
    :end-before: [END howto_operator_oss_bucket]