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)[原始碼]

當衍生此類別時覆寫。

此條目是否對您有幫助？