airflow.providers.airbyte.hooks.airbyte

属性

T

类

AirbyteHook

Airbyte API 的钩子。

模块内容

airflow.providers.airbyte.hooks.airbyte.T[源代码]
类 airflow.providers.airbyte.hooks.airbyte.AirbyteHook(airbyte_conn_id='airbyte_default', api_version='v1')[源代码]

基类: airflow.hooks.base.BaseHook

Airbyte API 的钩子。

参数:

  • airbyte_conn_id (str) – 可选。获取 Airbyte 连接信息所需的 Airflow 连接名称。默认为“airbyte_default”。

  • api_version (str) – 可选。Airbyte API 版本。默认为“v1”。

conn_name_attr = 'airbyte_conn_id'[源代码]
default_conn_name = 'airbyte_default'[源代码]
conn_type ='airbyte'[源代码]
hook_name = 'Airbyte'[源代码]
api_version: str = 'v1'[源代码]
airbyte_conn_id = 'airbyte_default'[源代码]
conn[源代码]
airbyte_api[源代码]
get_conn_params(conn_id)[源代码]
create_api_session()[源代码]

创建 Airbyte API 会话。

classmethod get_ui_field_behaviour()[源代码]

返回自定义字段行为。

get_job_details(job_id)[源代码]

使用 Http 异步调用检索 Airbyte 同步作业的特定元数据。

参数:

job_id (int) – Airbyte 同步作业的 ID。

get_job_status(job_id)[源代码]

检索 Airbyte 同步作业的特定状态。

参数:

job_id (int) – Airbyte 同步作业的 ID。

wait_for_job(job_id, wait_seconds=3, timeout=3600)[源代码]

轮询作业以检查其是否完成。

参数:

  • job_id (str | int) – 必需。Airbyte 作业 ID。

  • wait_seconds (float) – 可选。检查之间的秒数。

  • timeout (float | None) – 可选。等待作业就绪的秒数。仅当 asynchronous 为 False 时使用。

submit_sync_connection(connection_id)[源代码]
cancel_job(job_id)[源代码]

当任务被取消时，取消作业。

参数:

job_id (int) – 必需。Airbyte 作业 ID。

test_connection()[源代码]

通过调用健康检查 API 测试 Airbyte 连接。

此条目有帮助吗？