编写AWS Lambda函数以放入消防软管
我是Lambda的新手，正在尝试模拟一个简单的函数来执行Kinesis Fireshose的PUT。
我试着浏览AWS文档，但找不到任何确切的参考来编写一个简单的python脚本，以从API获取并通过Firehose将JSON发送到S3。下面是我试图发布到Lambda的代码，但我想按计划将其发送到Firehose，而不是文件系统。
# Get weather from OWM and use args for correct type.
def get_weather(gtype, lat, lon, key):
if gtype == 'current':
apitype = "weather?"
elif gtype == 'forecast':
apitype = "forecast?"
else:
print("Undefined GET type: use 'current' or 'forecast'.")
try:
api = "http://api.openweathermap.org/data/2.5/" + apitype
PARAMS = {'lat': lat, 'lon': lon, 'appid': key}
except:
return 'Invalid GET request'
with requests.session() as s:
rc = s.get(url=api, params=PARAMS)
data = rc.json()
return data
# Write data to json files.
def write_to_current(location, gtype, lat, lon, key):
with open(location + '/current.json', 'w') as outfile:
json.dump(get_weather(gtype, lat, lon, key), outfile)
return 'Current write complete.'
共有1个答案
这里有一个链接，指向AWS中编写到S3的示例代码以及用于Python的Amazon Web Services（AWS）SDK文档。
此外，您还可以查看Amazon Kinesis Data Firehose api参考文档
-
基于我对Kinesis数据流的阅读，我必须创建一个分析应用程序，然后将用于调用一个lambda。然后，我将不得不使用lambda写入S3。或者Kinesis数据流可以以某种方式直接写入lambda？我找不到任何表明相同的东西。 消防水带不按小时收费（而溪流是）。那么消防水管对我来说是更好的选择吗？
-
null 我如何解决这个问题？
-
我读过很多关于在firehose中添加换行符的类似问题，但都是关于在源代码中添加换行符。问题是我没有访问源的权限，第三方正在将数据传输到我们的Kinesis实例，我无法将“\n”添加到源。 我尝试使用以下代码进行firehose数据转换： 但是，这条新线仍然丢失了。我也尝试了JSON。stringify（record.data）“\n”但是我得到了一个无效的输出结构错误。
-
本文向大家介绍编写strcpy 函数相关面试题，主要包含被问及编写strcpy 函数时的应答技巧和注意事项，需要的朋友参考一下 已知strcpy 函数的原型是 char *strcpy(char *strDest, const char *strSrc);其中strDest是目的字符串， strSrc 是源字符串。 （1）不调用C++/C 的字符串库函数，请编写函数 strcpy 。 （2）str
-
我目前正试图用源SDK用C编写一个LookAt函数。我做了一些研究，发现了很多链接，但其中很多都是关于统一或Glm的，并且使用了四元数和旋转矩阵，但我不需要这些。 所以，我的问题是： 我在门户2。我有一个位置坐标为x，y，z的目标，我有我的球员的位置和他的旋转角度（偏航，俯仰，滚动）。当我使用目标坐标作为参数的函数时，我希望我的播放器看到目标<我发现：点看点，但效果不太好，最后的角度从来都不好。