airflow.providers.amazon.aws.sensors.glacier

JobStatus

Glacier 作業描述。

GlacierJobOperationSensor

用於檢查 Glacier 作業狀態的感測器。此運算子僅在 reschedule 模式下執行。

模組內容

airflow.providers.amazon.aws.sensors.glacier.JobStatus[source]

基類: enum.Enum

Glacier 作業描述。

IN_PROGRESS = 'InProgress'[source]
SUCCEEDED = 'Succeeded'[source]
airflow.providers.amazon.aws.sensors.glacier.GlacierJobOperationSensor(*, vault_name, job_id, poke_interval=60 * 20, mode='reschedule', **kwargs)[source]

基類: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.glacier.GlacierHook]

用於檢查 Glacier 作業狀態的感測器。此運算子僅在 reschedule 模式下執行。

另請參閱

有關如何使用此感測器的更多資訊,請參閱指南: 等待 Amazon Glacier 作業狀態

引數:
  • aws_conn_id – AWS 連線詳情的引用

  • vault_name (str) – 執行作業的 Glacier 保管庫名稱

  • job_id (str) – retrieve_inventory() 返回的作業 ID

  • poke_interval (int) – 作業在每次嘗試之間等待的秒數

  • mode (str) – 感測器如何執行。選項有: { poke | reschedule },預設為 poke。設定為 poke 時,感測器在其整個執行期間會佔用一個工作槽並在探測之間休眠。如果感測器的預期執行時間較短或需要較短的探測間隔,請使用此模式。請注意,在此模式下,感測器在其執行期間將佔用一個工作槽和一個池槽。設定為 reschedule 時,如果條件尚未滿足,感測器任務會釋放工作槽並在稍後重新排程。如果預計達到條件所需的時間很長,請使用此模式。探測間隔應大於一分鐘,以防止排程器負載過高。

aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
vault_name[source]
job_id[source]
poke_interval = 1200[source]
mode = 'reschedule'[source]
poke(context)[source]

派生此類時重寫此方法。

此條目有幫助嗎?