AWS 可延迟操作符

AWS 可延迟操作符依赖于 aiobotocore>=2.1.1 库。不幸的是,目前我们无法将其添加到核心 AWS 提供程序依赖项中,因为 aiobotocoreboto3 之间 botocore 的版本存在冲突。我们已将 aiobotocore 添加为附加依赖项。因此,如果您想使用 AWS 可延迟操作符,则必须自行管理此依赖项。

我们引入了一个异步钩子来异步管理与 AWS 服务之间的身份验证。 AWS 异步钩子目前支持默认的 botocore 身份验证机制,即如果未提供 Airflow 连接,则提供程序将尝试在环境变量中查找凭据参数。如果提供了 Airflow 连接,则使用 secret-key/access-key-id/profile/token 和 arn-method 的基本身份验证应该有效。

为了使用可延迟操作符,我们在支持可延迟执行的那些操作符中公开了 deferrable 参数。默认情况下,deferrable 设置为 False,将其设置为 True 以在异步模式下运行操作符。

此条目是否有帮助?