如何使用Airflow s3挂钩获取bucket策略



我想通过编程使用Airflow S3 Hook来了解特定S3 bucket的bucket策略是什么。boto3有get_bucket_policy方法,但S3钩子似乎没有。有没有任何方法可以使用S3钩子来实现这一点?谢谢

您得到一个调用S3Hook.get_bucket实例方法的boto3.S3.Bucket实例。

此实例有一个Policy方法,可用于访问与bucket关联的策略资源。

from airflow.providers.amazon.aws.hooks.s3 import S3Hook
s3_hook = S3Hook(aws_conn_id='aws_conn_id')
bucket = s3_hook.get_bucket('your-bucket-name')
policy_resource = bucket.Policy()
policy_json = policy_resource.policy

最新更新