`airflow.providers.apache.druid.operators.druid`¶

模組內容¶

類別¶

DruidOperator

允許直接向 Druid 提交任務。

class airflow.providers.apache.druid.operators.druid.DruidOperator(*, json_index_file, druid_ingest_conn_id='druid_ingest_default', timeout=1, max_ingestion_time=None, ingestion_type=IngestionType.BATCH, verify_ssl=True, **kwargs)[原始碼]¶

基底類別: airflow.models.BaseOperator

允許直接向 Druid 提交任務。

參數

json_index_file (str) – Druid 索引規格的檔案路徑
druid_ingest_conn_id (str) – 接受索引任務的 Druid Overlord 的連線 ID
timeout (int) – 輪詢 Druid 任務以獲取提取任務狀態的間隔（秒）。必須大於或等於 1
max_ingestion_time (int | None) – 假設任務失敗之前的最大提取時間
ingestion_type (airflow.providers.apache.druid.hooks.druid.IngestionType) – 任務的提取類型。可以是 IngestionType.Batch 或 IngestionType.MSQ
verify_ssl (bool) – 是否使用 SSL 加密提交索引任務。如果設定為 False，則檢查連線資訊中是否有要使用的 CA 捆綁包路徑。預設為 True

template_fields: collections.abc.Sequence[str] = ('json_index_file',)[原始碼]¶

template_ext: collections.abc.Sequence[str] = ('.json',)[原始碼]¶

template_fields_renderers[原始碼]¶

execute(context)[原始碼]¶

在建立運算子時衍生。

Context 是與渲染 Jinja 模板時使用的字典相同。

請參閱 get_template_context 以獲得更多上下文。

airflow.providers.apache.druid.operators.druid¶

模組內容¶

類別¶

`airflow.providers.apache.druid.operators.druid`¶