草庐IT

Python/Boto - 在没有序列 token 的情况下写入 AWS CloudWatch Logs

我正在尝试使用Python和Boto框架将日志发送到AWSCloudWatchLogs。我这样做:res=logs.put_log_events("FOO","BAR",[{'timestamp':int(round(time.time()*1000)),'message':time.strftime("%m/%d/%Y%H:%M:%S")+'Scheduledmonitoringcheck'}],sequence_token=None)每次运行都会报错:boto.logs.exceptions.InvalidSequenceTokenException:InvalidSequence

python - Boto3 使用旧凭据

我正在使用tkinter创建返回安全组的gui应用程序。目前,如果您想更改凭据(例如,如果您不小心输入了错误的凭据),则必须重新启动应用程序,否则boto3将继续使用旧凭据。我不确定为什么它一直使用旧凭据,因为我正在使用当前输入的凭据再次运行所有内容。这是设置环境变量和启动boto3的代码片段。如果您第一次输入正确的凭据,它会工作得很好。os.environ['AWS_ACCESS_KEY_ID']=self.accessKeyos.environ['AWS_SECRET_ACCESS_KEY']=self.secretKeyself.sts_client=boto3.client('

python - 有没有办法从 boto3 获取 access_key 和 secret_key?

这个问题在这里已经有了答案:Boto3:getcredentialsdynamically?(4个答案)关闭5年前。当我启动具有IAM角色的EC2实例时,我可以在该EC2实例上使用boto3而不必指定aws访问key和key,因为boto3readsthemautomatically.>>>importboto3>>>s3=boto3.resource("s3")>>>list(s3.buckets.all())[0]s3.Bucket(name='my-bucket-name')问题我想知道是否有任何方法可以从boto3获取访问key和key?例如,如何使用print将它们打印到标准

python - 如何连接到 boto 中的现有 CloudSearch 域?

我刚刚开始使用boto连接到AmazonCloudSearch。我得到了这些示例,但我找不到任何连接到现有域的示例,所有示例都创建了一个新域。四处寻找,我找到了get_domain,但如果我在连接对象上调用它,那将失败。>>>conn.get_domain('foo')Traceback(mostrecentcalllast):File"",line1,inAttributeError:'Layer2'objecthasnoattribute'get_domain'关于如何连接到现有域有什么建议吗?[编辑]我从这个开始:http://boto.cloudhackers.com/en/l

python - Boto3 Kinesis Video GetMedia 和 OpenCV

我正在尝试使用Boto3从kinesis获取视频流,然后使用OpenCV显示提要并同时将其保存到文件中。获取签名URL和Getmedia请求的过程似乎完美无缺,只是当我尝试使用OpenCV呈现它时,它似乎不起作用。数据正在挑衅地流向流importboto3importnumpyasnpimportcv2kinesis_client=boto3.client('kinesisvideo',region_name='eu-west-1',aws_access_key_id='ACC',aws_secret_access_key='KEY')response=kinesis_client.g

python - 如何在 AWS Lambda 函数中降级 boto3 版本

我需要在Lambda(Python3.7)中使用我自己的boto3版本。由于某种原因,Lambda默认Python3.7env(1.9.42)中包含的版本不支持使用Textract。为此,我根据guide执行了以下操作:使用以下命令创建自定义包:pipfreeze>requirements.txt将生成此文件:#requirements.txtboto3==1.9.138botocore==1.12.138docutils==0.14jmespath==0.9.4python-dateutil==2.8.0s3transfer==0.2.0six==1.12.0urllib3==1.2

python - boto EMR 添加步骤并自动终止

python2.7.12boto3==1.3.1如何向正在运行的EMR集群添加一个步骤并在该步骤完成后终止集群,无论它是失败还是成功?创建集群response=client.run_job_flow(Name=name,LogUri='s3://mybucket/emr/',ReleaseLabel='emr-5.9.0',Instances={'MasterInstanceType':instance_type,'SlaveInstanceType':instance_type,'InstanceCount':instance_count,'KeepJobFlowAliveWhenN

python - boto.s3 : copy() on a key object loses 'Content-Type' metadata

下面是一些复制S3key的示例代码。您可能想要这样做的原因有很多,其中之一就是更新关键元数据。虽然这似乎是广泛接受的解决方案,但存在一个大问题。问题是当我执行下面的示例时,我实际上丢失了我的Content-Type,它默认返回到“application/octet-stream”(如果尝试提供网络图像则不是很有用)。#Getbucketconn=S3Connection(self._aws_key,self._aws_secret)bucket=conn.get_bucket(self._aws_bucket)#Createkeyk=Key(bucket)k.key=key#Copyo

python - 通过django storages boto s3将二进制数据保存到模型上的文件中

我正在从echosignAPI中提取一个pdf,它提供了一个文件的字节数。我正在尝试获取这些字节并将它们保存到botos3支持的FileField中。我运气不太好。这是我得到的最接近的,但它在保存“扬声器”时出错,而且pdf虽然写入S3,但似乎已损坏。这里speaker是我的模型的一个实例,fileData是从echosignapi返回的'bytes'字符串afile=speaker.the_file=S3BotoStorageFile(filename,"wb",S3BotoStorage())afile.write(fileData)afile.close()speaker.sav

python - 使用 boto 列出自动缩放组中的实例

我想列出当前在AutoScaling组中运行的所有实例。可以用boto实现吗?ASG和实例之间一定存在某种关系,因为boto在boto.ec2.autoscale.group.AutoScalingGroup类中具有shutdown_instances方法。非常感谢任何指向正确方向的指示! 最佳答案 像这样的东西应该可以工作:>>>importboto>>>autoscale=boto.connect_autoscale()>>>ec2=boto.connect_ec2()>>>group=autoscale.get_all_gro