airflow.providers.alibaba.cloud.sensors.oss_key

OSSKeySensor

等待 OSS 存储桶中出现指定的键(OSS 上的类似文件的实例)。

模块内容

class airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor(bucket_key, region, bucket_name=None, oss_conn_id='oss_default', **kwargs)[source]

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

等待 OSS 存储桶中出现指定的键(OSS 上的类似文件的实例)。

OSS 是键值存储,不支持文件夹。路径仅表示键资源。

参数:
  • bucket_key (str) – 待监测的键。支持完整的 oss:// 风格 URL 或相对于根目录的相对路径。当使用完整的 oss:// URL 时,请将 bucket_name 保持为 None

  • region (str) – OSS 区域

  • bucket_name (str | None) – OSS 存储桶名称

  • oss_conn_id (str | None) – 用于 OSS 凭证的 Airflow 连接。

template_fields: collections.abc.Sequence[str] = ('bucket_key', 'bucket_name')[source]
bucket_name = None[source]
bucket_key[source]
region[source]
oss_conn_id = 'oss_default'[source]
poke(context)[source]

检查存储桶中是否存在该对象(键)。

参数:
返回:

如果对象存在则返回 True,否则返回 False

property get_hook: airflow.providers.alibaba.cloud.hooks.oss.OSSHook[source]

创建并返回一个 OSSHook。

property hook: airflow.providers.alibaba.cloud.hooks.oss.OSSHook[source]

创建并返回一个 OSSHook。

此条目是否有帮助?