当前位置: 首页 > news >正文

使用 AWS boto3 库从 s3 桶中批量下载数据

文章目录

  • 一、Boto3 快速安装
  • 二、账户配置
  • 三、代码示例
    • 3.1 下载单个文件
    • 3.2 下载文件夹内全部文件

官方文档

一、Boto3 快速安装

安装 Boto3 之前,先安装 Python 3.8 或更高版本;对 Python 3.6 及更早版本的支持已弃用。

通过 pip 安装最新的 Boto3 版本:

pip install boto3

使用 AWS Common Runtime (CRT)
除了默认安装 Boto3 之外,还可以选择包含新的 CRT。AWS CRT 是模块化包的集合,充当 AWS 开发工具包的新基础。每个库都为其实现的功能区域提供更好的性能和最小的占用空间。使用 CRT,开发工具包可以在可能的情况下共享相同的基本代码,从而提高 AWS 开发工具包之间的一致性和吞吐量优化。

但是,Boto3 默认情况下不使用 AWS CRT,但可以通过在安装 Boto3 时指定 crt 额外功能来选择使用它:

pip install boto3[crt]

要恢复到 Boto3 的非 CRT 版本,使用以下命令:

pip uninstall awscrt

如果需要重新启用 CRT,重新安装 boto3[crt] 以确保获得兼容版本 awscrt

二、账户配置

  1. 在代码中配置账户信息:
s3 = boto3.resource('s3', aws_access_key_id="", aws_secret_access_key="")
# s3 = boto3.client('s3', aws_access_key_id="", aws_secret_access_key="")
  1. 在电脑配置文件中配置账户信息(提前安装 AWS CLI):
    • 可以使用 aws configure 命令来修改配置文件;
    • 可以直接修改配置文件,默认情况下,配置文件的位置为 ~/.aws/credentials。配置文件至少应该指定 aws_access_key_idaws_secret_access_key

三、代码示例

3.1 下载单个文件

import boto3# 配置S3连接
s3 = boto3.resource('s3')
bucket_name = 'your-bucket-name'# 定义要下载的文件名
file_key = 'your-file-path-in-s3'# 下载文件
s3.Bucket(bucket_name).download_file(file_key, 'local-file-path')

3.2 下载文件夹内全部文件

def download_folder(bucket_name, folder, local_dir=None):"""Download an object from an S3 bucket"""count = 0bucket = s3.Bucket(bucket_name)for obj in bucket.objects.filter(Prefix=folder):target = obj.key #if local_dir is None else os.path.join(local_dir, os.path.relpath(obj.key, folder))if not os.path.exists(os.path.dirname(os.path.dirname(target))):os.makedirs(os.path.dirname(os.path.dirname(target)))# 额外下载文件夹中文件夹内的 object#if obj.key[-1] == '/':#    continuetarget_path = os.path.join(os.path.dirname(os.path.dirname(target)), target.split('/')[-1])bucket.download_file(obj.key, target_path)count += 1print("cont: ", count)
http://www.lryc.cn/news/238513.html

相关文章:

  • js ::after简单实战
  • 数据结构与算法实验(黑龙江大学)
  • 如何使用rclone将腾讯云COS桶中的数据同步到华为云OBS
  • gitlab
  • 3.计算机网络
  • Doris表的动态分区
  • docker小技能:部署mysql
  • “AI在未来”公益计划,亚马逊云科技将教育资源带到更多中西部学校
  • MyBatis的xml实现
  • dolphinscheduler任务莫名重跑
  • Modbus TCP/RTU协议转PROFINET协议网关
  • Caché for UNIX®, Linux及macOS的安装及配置
  • 【书籍篇】Git 学习指南(一)基础概念及入门
  • JWT知识点
  • UDP接收报文函数recvfrom和UDP发送报文函数sendto
  • Redisson 分布式锁实战应用解析
  • 【机器学习】对比学习(contrastive learning)
  • 开源和闭源的优劣势比较
  • html手势密码解锁插件(附源码)
  • Jetson JetPack-5.1.2-L4T-R35.4.1 修复deskew algorithm的问题
  • Doris的分区表和分桶表
  • 华为HCIE技术(HCIP、HCIE)汇总
  • React结合antd5实现整个表格编辑
  • 【C++进阶之路】第八篇:智能指针
  • 保护服务器免受攻击:解析攻击情境与解决之道
  • Python 获取两个数组中各个坐标点对之间最短的欧氏距离
  • 假ArrayList导致的线上事故......
  • K8S精进之路-控制器Deployment-(1)
  • flutter iOS 视频mov格式转MP4格式
  • datafilecopy header validation failure for file +DATA/orcl/datafile/file1.ora