我有一個如下所示的氣流連接：
- 聯系方式：
my_conn_id - 連接型別：
s3 - 主持人：
my_host - 登錄：
abcd
我嘗試使用以下代碼使用 boto3 連接到我的 s3，但沒有成功
s3client = boto3.client(
service_name='s3',
region_name='us-east-1',
aws_access_key_id="{{ conn.conn_id.host }}",
aws_secret_access_key="{{ conn.conn_id.host }}"
)
任何幫助，將不勝感激
uj5u.com熱心網友回復：
您的連接配置錯誤。輸入您的 aws_access_key_id 作為登錄名，輸入 aws_secret_key_id 作為密碼。當您生成 AWS 密鑰時，您同時獲得了訪問密鑰和秘密密鑰 - 您將同時需要它們。如果您沒有密鑰，請在 AWS 中重新生成密鑰。在此處查看連接詳細資訊 - Airflow AWS 連接
在 Airflow 中，如果需要，您應該使用 S3Hook 生成 boto3 S3 客戶端，但請先檢查 S3Hook 的功能，看看您是否可以使用它來完成您的任務。在此處查看函式 - S3Hook 源代碼
from airflow.providers.amazon.aws.hooks.s3 import S3Hook
s3client = S3Hook(aws_conn_id=my_conn_id).get_conn()
轉載請註明出處，本文鏈接：https://www.uj5u.com/qukuanlian/408997.html
標籤：