updated lambda to reduce traffic
This commit is contained in:
@@ -1,3 +1,5 @@
|
|||||||
|
from time import sleep
|
||||||
|
|
||||||
import boto3
|
import boto3
|
||||||
import simplejson as json
|
import simplejson as json
|
||||||
import os
|
import os
|
||||||
@@ -19,7 +21,7 @@ def store(event, context):
|
|||||||
|
|
||||||
for x in data:
|
for x in data:
|
||||||
print("storing data: {}".format(x))
|
print("storing data: {}".format(x))
|
||||||
|
sleep(0.5) # throttle to not overwhelm the DB, lambda is cheaper than dynamo
|
||||||
get_trade_table().put_item(Item=x)
|
get_trade_table().put_item(Item=x)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user