lobo/etags
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

add automatic table creation

Browse Source
This commit is contained in:
Emil Lerch 2020-11-25 12:07:12 -08:00
parent b8f72d2705
commit bbc4920c4c
Signed by: lobo
GPG Key ID: A7B62D657EF764F8
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
etags.py
View File

@ -28,13 +28,25 @@ def ddb_url(url):
def all_etags(urls):
response = ddb.batch_get_item(RequestItems={table: {
'Keys': [ddb_url(url) for url in urls],
}})
rc = {}
for item in response['Responses'][table]:
rc[item['PK']['S']] = item['etag']['S']
return rc
try:
response = ddb.batch_get_item(RequestItems={table: {
'Keys': [ddb_url(url) for url in urls],
}})
rc = {}
for item in response['Responses'][table]:
if 'etag' in item:
rc[item['PK']['S']] = item['etag']['S']
return rc
except Exception as ex:
printerr("Exception getting items: %s. Creating table", ex)
response = ddb.create_table(
TableName = table,
AttributeDefinitions = [
{ 'AttributeName': 'PK', 'AttributeType': 'S' }
],
KeySchema = [ { 'AttributeName': 'PK', 'KeyType': 'HASH' } ],
)
return all_etags(urls)
def create_put_request(item):