updated lambda to reduce traffic
This commit is contained in:
parent
ecca676c07
commit
1611cd8124
@ -15,8 +15,11 @@ def store(event, context):
|
|||||||
for x in event['Records']:
|
for x in event['Records']:
|
||||||
if 'Sns' in x and 'Message' in x['Sns']:
|
if 'Sns' in x and 'Message' in x['Sns']:
|
||||||
data = json.loads(x['Sns']['Message'], use_decimal=True)
|
data = json.loads(x['Sns']['Message'], use_decimal=True)
|
||||||
print("storing data: {}".format(data))
|
print("storing {} data trade results".format(len(x)))
|
||||||
|
|
||||||
for x in data:
|
for x in data:
|
||||||
|
print("storing data: {}".format(x))
|
||||||
|
|
||||||
get_trade_table().put_item(Item=x)
|
get_trade_table().put_item(Item=x)
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user