airflow.providers.apache.kafka.hooks.base¶

類¶

KafkaBaseHook

用於與 Apache Kafka 互動的基礎 Hook。

模組內容¶

class airflow.providers.apache.kafka.hooks.base.KafkaBaseHook(kafka_config_id=default_conn_name, *args, **kwargs)[原始碼]¶

繼承自: airflow.hooks.base.BaseHook

用於與 Apache Kafka 互動的基礎 Hook。

引數:: kafka_config_id – 要使用的連線物件，預設為“kafka_default”

conn_name_attr = 'kafka_config_id'[原始碼]¶

default_conn_name = 'kafka_default'[原始碼]¶

conn_type = 'kafka'[原始碼]¶

hook_name = 'Apache Kafka'[原始碼]¶

kafka_config_id = 'kafka_default'[原始碼]¶

classmethod get_ui_field_behaviour()[原始碼]¶

返回自定義欄位行為。

property get_conn: Any[原始碼]¶

獲取配置物件。

test_connection()[原始碼]¶

從 UI 測試連線。

此條目有幫助嗎？