`airflow.providers.amazon.aws.sensors.glacier`¶

模块内容¶

类¶

`JobStatus`	Glacier 作业描述。
`GlacierJobOperationSensor`	用于检查作业状态的 Glacier 传感器。此操作符仅在重新调度模式下运行。

class airflow.providers.amazon.aws.sensors.glacier.JobStatus[源代码]¶

基类: enum.Enum

Glacier 作业描述。

IN_PROGRESS = 'InProgress'[源代码]¶

SUCCEEDED = 'Succeeded'[源代码]¶

class airflow.providers.amazon.aws.sensors.glacier.GlacierJobOperationSensor(*, vault_name, job_id, poke_interval=60 * 20, mode='reschedule', **kwargs)[源代码]¶

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

用于检查作业状态的 Glacier 传感器。此操作符仅在重新调度模式下运行。

参见

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon Glacier 作业状态

参数

aws_conn_id – 对 AWS 连接详细信息的引用
vault_name (str) – 执行作业的 Glacier vault 的名称
job_id (str) – 由 retrieve_inventory() 返回的作业 ID
poke_interval (int) – 作业在每次尝试之间应等待的秒数
mode (str) – 传感器如何运行。选项包括： { poke | reschedule }，默认为 poke。当设置为 poke 时，传感器在其整个执行时间内占用一个 worker 插槽，并在轮询之间休眠。如果传感器的预期运行时间较短或需要较短的轮询间隔，请使用此模式。请注意，在此模式下，传感器将在传感器的运行时占用一个 worker 插槽和一个池插槽。当设置为 reschedule 时，如果尚未满足条件，传感器任务会释放 worker 插槽，并在稍后重新调度。如果预计满足条件之前的时间会很长，请使用此模式。轮询间隔应大于一分钟，以防止调度程序负载过重。

aws_hook_class[源代码]¶

template_fields: collections.abc.Sequence[str][源代码]¶

poke(context)[源代码]¶

在派生此类时覆盖。

airflow.providers.amazon.aws.sensors.glacier¶

模块内容¶

类¶

`airflow.providers.amazon.aws.sensors.glacier`¶