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]¶

派生此类时重写此方法。