python调用rest api_调用rest api使用python将数据推送到运动学
我是python和aws的新手.我不知道如何在stackoverflow中提出问题.
请不要阻止我.
我正在尝试发送HTTP发布请求以将记录放入Amazon Kinesis Stream.
我在运动学中创建了一个流mystream.我使用方法发布.
我尝试了以下链接来设置网关api,它工作正常.
我正在尝试使用请求的python代码来做到这一点.
但是我收到以下提到的错误:
以下是我的代码:
import sys, os, base64, datetime, hashlib, hmac
import requests # pip install requests
# ************* REQUEST VALUES *************
method = 'POST'
service = 'kinesis'
host = 'kinesis.eu-west-1.amazonaws.com'
region = 'eu-west-1'
endpoint = 'https://kinesis.eu-west-1.amazonaws.com'
content_type = 'application/x-amz-json-1.1'
amz_target = 'Kinesis_20181114.PutRecord'
request_parameters = '{'
request_parameters += '"StreamName": mystream,'
request_parameters += '"Data": + base64.b64encode(test) + ,'
request_parameters += '"PartitionKey": 1234 '
request_parameters += '}'
# Key derivation functions. See:
# http://docs.aws.amazon.com/general/latest/gr/signature-v4-
examples.html#signature-v4-examples-python
def sign(key, msg):
return hmac.new(key, msg.encode('utf-8'), hashlib.sha256).digest()
def getSignatureKey(key,datestamp,region,service):
kDate = sign(('AWS4' +key ).encode('utf-8'), datestamp)
kRegion = sign(kDate,region)
kService = sign(kRegion,service)
kSigning = sign(kService, 'aws4_request')
return kSigning
# Read AWS access key from env. variables or configuration file. Best
practice is NOT
# to embed credentials in code.
with open ('C:\Users\Connectm\Desktop\acesskeyid.txt') as f:
contents = f.read().split('
')
access_key = contents[0]
secret_key = contents[1]
if access_key is None or secret_key is None:
print('No access key is available.')
sys.exit()
# Create a date for headers and the credential string
t = datetime.datetime.utcnow()
amzdate = t.strftime('%Y%m%dT%H%M%SZ')
datestamp = t.strftime('%Y%m%d') # Date w/o time, used in credential scope
canonical_uri = '/'
canonical_querystring = ''
canonical_headers = 'content-type:' + content_type + '
' + 'host:' + host +
'
' + 'x-amz-date:' + amzdate + '
' + 'x-amz-target:' + amz_target + '
'
signed_headers = 'content-type;host;x-amz-date;x-amz-target'
payload_hash = hashlib.sha256(request_parameters).hexdigest()
canonical_request = method + '
' + canonical_uri + '
' +
canonical_querystring + '
' + canonical_headers + '
' + signed_headers +
'
' + payload_hash
algorithm = 'AWS4-HMAC-SHA256'
credential_scope = datestamp + '/' + region + '/' + service + '/' +
'aws4_request'
string_to_sign = algorithm + '
' + amzdate + '
' + credential_scope +
'
' + hashlib.sha256(canonical_request).hexdigest()
signing_key = getSignatureKey(secret_key, datestamp, region, service)
signature = hmac.new(signing_key, (string_to_sign).encode('utf-8'),
hashlib.sha256).hexdigest()
authorization_header = algorithm + ' ' + 'Credential=' + access_key + '/' +
credential_scope + ', ' + 'SignedHeaders=' + signed_headers + ', ' +
'Signature=' + signature
print authorization_header;
headers = {'Content-Type':content_type,
'X-Amz-Date':amzdate,
'X-Amz-Target':amz_target,
'Authorization':authorization_header}
# ************* SEND THE REQUEST *************
print '
BEGIN REQUEST++++++++++++++++++++++++++++++++++++'
print 'Request URL = ' + endpoint
r = requests.post(endpoint, data=request_parameters, headers=headers)
print '
RESPONSE++++++++++++++++++++++++++++++++++++'
print 'Response code: %d
' % r.status_code
print r.text
我收到以下错误
AWS4-HMAC-SHA256凭证= AKIAI5C357A6YSKQFXEA / 20181114 / eu-west-
?1 /运动/ aws4_request,SignedHeaders =内容类型;主机; x-amz日期; x-amz-
?目标,
?签名= 1d7d463e77beaf8693080681212188180db9cc7cff082663ad547f647a9c6d545a
响应
?响应码:400
{“ __type”:“ SerializationException”}
请有人可以解释我如何纠正以上错误吗?
代码是否已连接到流?有关
?数据序列化?
python调用rest api_调用rest api使用python将数据推送到运动学相关推荐
- 【电竞数据】电竞实时指数数据API接口调用和数据推送
[电竞数据]电竞实时指数数据API接口调用和数据推送 实时指数数据接口和推送 说明 用来获取(无延迟)实时指数和玩法状态推送 当指数数据发生变化时,破晓字节电竞数据API接口会通过websocket推 ...
- python爬虫如何实现每天爬取微信公众号的推送文章
python爬虫如何实现每天爬取微信公众号的推送文章 上上篇文章爬虫如何爬取微信公众号文章 上篇文章python爬虫如何爬取微信公众号文章(二) 上面的文章分别介绍了如何批量获取公众号的历史文章url ...
- 钉钉一行代码_利用Python快速搭建钉钉和邮件数据推送系统
前面的文章我们写到了利用Python实现钉钉和邮件的数据推送,在数据处理这一块实现了对mysql和odps的数据获取和处理,可以满足常规业务大部分数据场景需求,在一家初创公司数据基础建设还不完善的时候 ...
- .net web api微信开放平台接收推送component_verify_ticket
1.关于盛派的微信第三方接口确实很实用,先强烈安利一波,详细接口内容可去官网根据需求调用Senparc 官方微信开发教程文档 2.先在NuGet上引用开放平台的Senparc.Weixin.dll.S ...
- python实现新闻网站_Python+MySQL+HTML5技术实现一个新闻定制推送系统
三.研究的基本思路和方法.技术路线.实验方案及可行性分析 (一)基本思路和方法 1.数据库的建立 确定模块与模块之间的关系,遵循数据库设计的原则,设计好数据库表.字段,并且要方便后期的维护. 2.系统 ...
- 用Python写个爬虫小程序,给女朋友每日定时推送睡前小故事
导读:这篇文章利用简单的Python爬虫.邮件发送以及定时任务实现了每天定时发送睡前小故事的功能,是一篇步骤详尽的文章. 最近,某可爱要求我忙完之后给她每晚睡前讲讲小故事,我想了下,网络上应该有各种资 ...
- python 实时数据推送_python scrapy 爬取金十数据并自动推送到微信
一.背景 因业务需要获取风险经济事件并采取应对措施,但因为种种原因又疏忽于每天去查看财经日历,于是通过爬取金十数据网站并自动推送到微信查看. 二.目标实现 image 三.环境与工具 1.pychar ...
- python b站自动签到_b站天选微信自动推送
天选中奖自动推送 首先需要在http://sc.ftqq.com/3.version 注册申请SCKEY 然后在./conf/BiliBiliHelper.conf中填写bilibili账号密码 和 ...
- 对接快递100快递管家API之快递单号推送接口
1.功能描述 快递面单打印后,系统将快递单号回推给贵方,可直接用于发货等操作: 2.接口信息 请求的Content-Type:application/json;charset=UTF-8 3.请求 ...
最新文章
- Alpha版本项目展示
- [How TO]-ubuntu下快速搭建http
- jQuery选择器 (详解)
- Linux下进程通信的八种方法
- spring4.0:@Configuration的使用
- flutter 返回指定界面_Flutter 即学即用系列博客——04 Flutter UI 初窥
- LA 4287 有相图的强连通分量
- linux命令ftps,Linux下ftp+ssl实现ftps
- 在虚幻引擎5中构建你的首款游戏 - 03 - 模型和材质蓝图
- 微信开放平台Android应用签名的获取
- 基于ML或DL的iot ddos detection 文献整理
- ROS机器人学习历程三:Publisher 和Subscriber
- Socket和Sock之间同步机制
- STM32学习笔记---触摸屏
- 经典神经网络论文超详细解读(三)——GoogLeNet InceptionV1学习笔记(翻译+精读+代码复现)
- 计算机模拟泊松分布,第19讲 计算机模拟matlb.ppt
- 软件需求分析——需求的理论基础
- linux奶瓶U盘使用方法,U盘安装BEINI(奶瓶)教程+多功能启动
- java实现ftp跨服务器上传文件并用html5流媒体播放
- Orbit Downloader 1.5.4多国语言版