`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)[源代码]¶

基类: airflow.sensors.base.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 连接。

property get_hook: airflow.providers.alibaba.cloud.hooks.oss.OSSHook[源代码]¶

创建并返回一个 OSSHook。

template_fields: collections.abc.Sequence[str] = ('bucket_key', 'bucket_name')[源代码]¶

poke(context)[源代码]¶

检查对象是否存在于存储桶中以拉取键。

参数

self – 对象本身
context (airflow.utils.context.Context) – 对象的上下文

返回

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

hook()[源代码]¶

创建并返回一个 OSSHook。

airflow.providers.alibaba.cloud.sensors.oss_key¶

模块内容¶

类¶

`airflow.providers.alibaba.cloud.sensors.oss_key`¶