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

在创建操作符时派生。

上下文与呈现 Jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

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

模块内容¶

类¶

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