boto3 相关问题

Boto 3 - 适用于Python的Amazon Web Services(AWS)SDK

如何使用 Boto3 (Python) 列出可用区域

随着 AWS 扩展并添加新区域,我希望我的代码能够自动检测到这一点。目前,“选择您的区域”是硬编码的,但我想仅解析以下区域...

回答 3 投票 0

Python CSV:从 S3 追加数据,重复条目

仅供参考,我是一个完全的Python新手。我有一个 for 循环,它从 S3 存储桶中提取一些对象信息并将其填充到 csv 文件中。对于检索详细信息的每个对象,我...

回答 2 投票 0

aws boto3 库,函数describe_key_pairs 不会像文档中那样返回公钥字段

响应 = self.ec2.describe_key_pairs( 键名=[ 姓名, ], IncludePublicKey=True, ).get("密钥对") boto2 1.34.61 的文档 反应...

回答 1 投票 0

从 python lambda 函数获取 s3 存储桶中文件夹中的文件数量

是否可以使用 python 从 lambda 函数获取 s3 存储桶中特定文件夹中的文件(对象)数量。

回答 2 投票 0

检查S3存储桶中是否存在文件夹,如果不存在则创建一个文件夹

我正在尝试编写一段代码,其中在S3存储桶中我想检查该文件夹是否存在,如果不存在,我想创建该文件夹。以下是我的代码。 def checkiffolderexists(存储桶:str, 路径:str...

回答 2 投票 0

如何为非美国区域的 S3 存储桶创建虚拟托管式预签名 URL?

我尝试使用 boto3 库为 me-central-1 区域中的 S3 存储桶生成预签名 URL,如下所示 客户端= boto3.client(“s3”,region_name =“me-centra...

回答 1 投票 0

使用 boto3 将文件上传到 s3 存储桶:CERTIFICATE_VERIFY_FAILED

我正在使用 boto3 将文件上传到 s3 存储桶 这是我正在使用的代码 # s3客户端初始化 s3_client = boto3.client( service_name='s3', Region_name='us-west-2',

回答 1 投票 0

AWS SageMaker 使用 start_pipeline_exection boto3 函数将参数从 Pipeline 传递给 NotebookJobStep

我正在尝试使用本地的 sagemaker 资源以编程方式触发 sagemaker 笔记本。我在 sagemaker 管道步骤中遇到了 NotebookJobStep。我已经成功创建了一个

回答 1 投票 0

使用boto3将文件上传到s3存储桶

我正在使用 boto3 将文件上传到 s3 存储桶 这是我正在使用的代码 s3客户端初始化 service_name='s3', Region_name='us-west-2', aws_access_key_id=access_key,

回答 1 投票 0

验证 EC2 中的 boto3 是否正在使用 VPC 端点连接到 S3?

如何验证 EC2 中的 boto3.client('s3') 是否正在使用 VPC 终端节点? 在AWS中,我创建了一个VPC端点(服务= s3,类型=网关)。据我了解,boto 会自动选择它的客户端(

回答 1 投票 0

Dynamodb - 不精确:[<class 'decimal.Inexact'>,<class 'decimal.Rounded'>]

我在尝试上传到 DynamoDb 时遇到了这个错误,完全迷失了方向。我正在尝试将 Shodan API 响应上传到表。 响应 = [{}, {}, {<

回答 2 投票 0

如何使用boto3和lambda从S3存储桶中的html页面上传文件?

我想将一个大于 10 MB 的文件从 html 页面上传到 S3。 我有html: 我想将一个大于 10 MB 的文件从 html 页面上传到 S3。 我有 html: <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8" /> <meta http-equiv="X-UA-Compatible" content="IE=edge" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> <title>Upload File to S3 Bucket</title> </head> <body> <h3>Upload File to S3 Bucket</h3> <form action=" https://4oss3kkck9.execute-api.us-east-1.amazonaws.com/api/uploadhtml" method="post" enctype="multipart/form-data" > <h1>Select File:</h1> <input type="file" name="file" /> <input type="submit" name="submit" value="Upload" /> </form> </body> </html> 我有由 API 端点触发的 lambda 函数: 这是 Lambda: import json import base64 import boto3 import email import logging import botocore from create_bucket import create_bucket def lambda_handler(event, context): s3 = boto3.client('s3') buckets = s3.list_buckets() bucket_name = "" bucket_without_extension = "filetypewithoutextension" print("Received event: " + json.dumps(event)) # decoding form-data into bytes post_data = base64.b64decode(event["body"]) # fetching content-type try: content_type = event["headers"]["content-Type"] except: content_type = event["headers"]["content-type"] # concate Content-Type: with content_type from event ct = "Content-Type: "+content_type+"\n" # parsing message from bytes msg = email.message_from_bytes(ct.encode()+post_data) print(msg) # checking if the message is multipart print("Multipart check : ", msg.is_multipart()) # if message is multipart if msg.is_multipart(): multipart_content = {} # retrieving form-data for part in msg.get_payload(): # checking if filename exist as a part of content-disposition header if part.get_filename(): # fetching the filename file_name = part.get_filename() bucket_name = f"thisismycomplicatedbucketfiletype-{file_name.split('.')[-1]}" multipart_content[part.get_param("name", header="content-disposition")] = part.get_payload(decode=True) in_bucket = False if len(file_name.split(".")) == 1 or file_name.split(".")[1] == "": s3.put_object(Bucket=bucket_without_extension, Key=file_name, Body=multipart_content["file"], ServerSideEncryption="aws:kms") return { "statusCode": 200, "body": json.dumps("File uploaded successfully!") } for bucket in buckets["Buckets"]: if bucket_name in bucket["Name"]: s3.put_object(Bucket=bucket_name, Key=file_name, Body=multipart_content["file"], ServerSideEncryption="aws:kms") in_bucket = True break if not in_bucket: create_bucket(bucket_name) s3.put_object(Bucket=bucket_name, Key=file_name, Body=multipart_content["file"], ServerSideEncryption="aws:kms") # on upload success return { "statusCode": 200, "body": json.dumps("File uploaded successfully!") } else: # on upload failure return { "statusCode": 500, "body": json.dumps("Upload failed!") } 但这仅适用于最大 10 MB 的文件。我想上传所有文件扩展名,还有小文件和大于 10 MB 的文件? 如何修改此代码?预签名网址?分段上传? 我不确定如何实现这个? 谢谢! 文件大于 10 MB? 遗憾的是,您无法通过 API 网关执行此操作。它的硬限制是10 MB。常见的解决方法是使用 S3 预签名 urls 将文件上传到 S3。这需要更改您的架构,因为上传到 S3 时您无法使用 API 网关。 您好,我可以知道您如何创建用于集成 lambda 的 api 网关以及您将在 lambda 中的何处运行此 html

回答 2 投票 0

从 S3 下载文件时,AWS Lambda 中出现“只读文件系统”错误

当我将 file.csv 放入 S3 存储桶时,我在 lambda 函数中看到以下错误。文件并不大,我什至在打开文件进行阅读之前添加了 60 秒的睡眠,但是为了......

回答 5 投票 0

哪种方法可以更有效地获取 dynamodb 项目的子集?

我有一个dynamodb表和该表所有主键的列表。 示例项目的 PK 可能为“foo_12424”,SK 为“bar_32456” 我想获取所有以 sk 开头的项目...

回答 1 投票 0

AWS |雅典娜 | Boto3 - 检索具有名称或 ID 的查询的所有执行详细信息

我浏览了整个 boto3 文档,似乎无法检索特定查询的执行详细信息。我能看到的唯一方法是获取所有

回答 2 投票 0

使用过滤器表达式和行限制从 dynamodb 查询返回恒定数量的行

我有一个 dynamodb 表,看起来像这样 资源 = boto3.resource("dynamodb") resource.create_table(TableName="mytable", KeySchema=[{"AttributeName": "pk&quo...

回答 1 投票 0

配置 AWS GuardDuty 将调查结果通知发布到 Slack

我有一个使用 boto3 与 AWS 服务交互的 Python 脚本。我正在尝试集成此脚本,以便一旦执行,它就会激活 GuardDuty 并创建一个逻辑来转发高严重性

回答 1 投票 0

AWS Batch 处于特权模式 urllib3.exceptions.ConnectTimeoutError + botocore.exceptions.ConnectTimeoutError

我的特权模式下的 AWS Batch 作业存在以下 boto/botocore 问题: 超时错误:超时 上述异常是导致以下异常的直接原因: urllib3.异常。

回答 1 投票 0

如何可靠地判断 AWS RDS 修改操作何时完成?

我在一个小脚本中使用 boto3 来更改 RDS 集群的主凭据。 问题在于,describe_db_clusters 中的 RDS 集群状态不是可靠的最新状态。当我发出

回答 3 投票 0

使用 Boto3 通过 Python 将图像上传到 Amazon S3 的最有效方法

我正在实现 Boto3 将文件上传到 S3,一切正常。我正在做的过程如下: 我从 FileReader Javascript 对象获取 base64 图像。然后我通过ajax发送base64...

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.