`airflow.providers.alibaba.cloud.sensors.analyticdb_spark`¶

模块内容¶

类¶

AnalyticDBSparkSensor

监控 AnalyticDB Spark 会话是否终止。

class airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor(*, app_id, adb_spark_conn_id='adb_spark_default', region=None, **kwargs)[源代码]¶

基类: airflow.sensors.base.BaseSensorOperator

监控 AnalyticDB Spark 会话是否终止。

参数

app_id (str) – 被监控应用程序的标识符，取决于正在修改的选项。
adb_spark_conn_id (str) – 对预定义的 ADB Spark 连接的引用。
region (str | None) – 您想要提交 Spark 应用程序的 AnalyticDB MySQL 区域。

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

hook()[源代码]¶

获取有效 hook。

poke(context)[源代码]¶

继承此类时覆盖。

airflow.providers.alibaba.cloud.sensors.analyticdb_spark¶

模块内容¶

类¶

`airflow.providers.alibaba.cloud.sensors.analyticdb_spark`¶