def _get_employee_info_from_s3():
logging.info('Reading employees file from S3...')
key = Key(
connect_s3(
aws_access_key_id=get_secret('AWS_ACCESS_KEY_ID'),
aws_secret_access_key=get_secret('AWS_SECRET_ACCESS_KEY'),
).get_bucket(config.S3_BUCKET),
'employees.json',
)
employee_dicts = json.loads(key.get_contents_as_string())
logging.info('Done.')
return employee_dicts
评论列表
文章目录