airflow.providers.airbyte.sensors.airbyte¶

此模块包含 Airbyte 作业传感器。

类¶

AirbyteJobSensor

检查之前提交的 Airbyte 作业的状态。

模块内容¶

class airflow.providers.airbyte.sensors.airbyte.AirbyteJobSensor(*, airbyte_job_id, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), airbyte_conn_id='airbyte_default', api_version='v1', **kwargs)[源代码]¶

Bases: airflow.sensors.base.BaseSensorOperator

检查之前提交的 Airbyte 作业的状态。

参数:

airbyte_job_id (int) – 必需。Airbyte 作业的 ID。
airbyte_conn_id (str) – 可选。用于获取 Airbyte 连接信息的 Airflow 连接名称。默认为“airbyte_default”。
deferrable (bool) – 可选。以可延迟模式运行传感器。默认为配置值“default_deferrable”，如果未定义则为 False。
api_version (str) – 可选。Airbyte API 版本。默认为“v1”。

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

ui_color = '#6C51FD'[源代码]¶

deferrable = True[源代码]¶

airbyte_conn_id = 'airbyte_default'[源代码]¶

airbyte_job_id[源代码]¶

api_version = 'v1'[源代码]¶

poke(context)[源代码]¶

派生此类时覆盖。

execute(context)[源代码]¶

提交生成 run_id 并可延迟的作业。

execute_complete(context, event=None)[源代码]¶

当触发器触发时调用此回调；立即返回。

依赖触发器抛出异常，否则假定执行成功。