我正在使用 Apache Beam python SDK 來讀取 s3 檔案資料。
我正在使用的代碼
ip = (pipe
| beam.io.ReadFromText("s3://bucket_name/file_path")
| beam.Map(lambda x: x.split(","))
| beam.Map(print)
)
但它給出了一個錯誤
S3ClientError('Unable to locate credentials', None)}")}
任何人都知道如何通過 apache Beam python 檔案向 s3 客戶端提供憑據
uj5u.com熱心網友回復:
您需要確保憑據在您的作業機器上可用。如果您使用的是資料流,則可以將它們安裝在自定義容器中。
轉載請註明出處,本文鏈接:https://www.uj5u.com/shujuku/470542.html