in lambda_code/glacier_select.py [0:0]
def lambda_handler(event, context):
#glacier block
logger.info('starting glacier block')
print(archiveid)
try:
jobParameters = {"Type": "select", "ArchiveId": archiveid,"Tier": "Standard", "SelectParameters": {
"InputSerialization": {"csv": {}},
"ExpressionType": "SQL",
"Expression": "select s._1,s._2,s._3,s._4,s._5,s._12,s._13 from archive s where CAST(s._2 AS DECIMAL) >= 500000",
"OutputSerialization": {
"csv": {}
}
},
"OutputLocation": {
"S3": {"BucketName": s3bucket, "Prefix":s3prefix}
}
}
response=glacier.initiate_job(vaultName=vault, jobParameters=jobParameters)
except Exception as e:
print(e)
print("Error selecting data from archive ", archiveid, "from vault ", vault, "to bucket",s3bucket)
raise e
logger.info('downloaded data from glacier archive')
print(response)
return response