airflow.providers.alibaba.cloud.sensors.oss_key¶
类¶
等待 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 是键值存储,不支持文件夹。路径仅表示键资源。
- 参数:
- template_fields: collections.abc.Sequence[str] = ('bucket_key', 'bucket_name')[source]¶
- poke(context)[source]¶
检查存储桶中是否存在该对象(键)。
- 参数:
self – 对象本身
context (airflow.sdk.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。