我有一个lambda函数,它使用带rate-5的云表触发器运行,该触发器通过API提取数据并将其插入数据库。我想每天向报表生成器添加另一个云表触发器。我的代码是这样的
def run_data_capture():
data = api_call()
insert_data(data)
def run_generate_report():
data = query_table()
csv = generate_csv(data)
def handler(event, context):
run_data_capture()处理程序是我的lambda函数正在调用的方法。如果我添加了另一个cloudwatch触发器,以便每天运行一次,如何确定哪个触发器正在调用处理程序,以便可以执行以下操作:
def hander(event, context):
if 5MinuteEvent:
run_data_capture()
elif dailyEvent:
run_generate_report()发布于 2017-09-25 19:34:37
当一个lambda函数被调用时,调用它的事件作为事件对象传递给处理程序。
这里是亚马逊调用lambda函数的示例。他们给
{
"version": "0",
"id": "53dc4d37-cffa-4f76-80c9-8b7d4a4d2eaa",
"detail-type": "Scheduled Event",
"source": "aws.events",
"account": "123456789012",
"time": "2015-10-08T16:53:06Z",
"region": "us-east-1",
"resources": [
"arn:aws:events:us-east-1:123456789012:rule/my-scheduled-rule"
],
"detail": {}
}作为从coudwatch传递给lambda的对象的一个例子。如果解析该对象并比较“细节类型”数据或“源”,它将为您提供所需的信息,以确定哪些cloudwatch函数正在调用lambda函数。示例:
def handler(event, context):
event_type = event['source']
if event_type == '5MinuteEvent':
run_data_capture()
elif event_type == 'dailyEvent':
run_generate_report()https://stackoverflow.com/questions/46411884
复制相似问题