airflow.providers.alibaba.cloud.sensors.oss_key¶
类¶
等待一个 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 是键/值存储,不支持文件夹。路径只是一个键资源。
- 参数:
- template_fields: collections.abc.Sequence[str] = ('bucket_key', 'bucket_name')[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 对象。