airflow.providers.alibaba.cloud.sensors.oss_key

OSSKeySensor

等待一个 key (在 OSS 上的一个文件对象) 存在于 OSS bucket 中。

模块内容

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

基类: airflow.sensors.base.BaseSensorOperator

等待一个 key (在 OSS 上的一个文件对象) 存在于 OSS bucket 中。

OSS 是键/值存储,不支持文件夹。路径只是一个键资源。

参数:
  • bucket_key (str) – 正在等待的 key。支持完整的 oss:// 格式 URL 或从根级别的相对路径。当指定为完整的 oss:// URL 时,请将 bucket_name 留空 (None)。

  • region (str) – OSS 区域

  • bucket_name (str | None) – OSS bucket 名称

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

检查对象是否存在于 bucket 中。

参数:
  • self – 对象本身

  • context (airflow.utils.context.Context) – 对象的上下文

返回值:

如果对象存在则返回 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 对象。

此条目是否有帮助?