Alec Ryan
04/14/2022, 9:06 PMfrom dagster_aws.s3 import s3_resource
@op(required_resource_keys={'s3'})
def load_json_to_s3(context, json_game_data_list):
for json in json_game_data_list:
context.resources.s3.put_object(
body=json,
Bucket='nhl-analytics',
Prefix='test'
)
johann
04/14/2022, 9:16 PMAWS_ACCESS_KEY_ID
and AWS_SECRET_ACCESS_KEY
Zach
04/14/2022, 9:19 PMAlec Ryan
04/14/2022, 9:19 PMjohann
04/14/2022, 9:20 PMAlec Ryan
04/14/2022, 9:21 PMjohann
04/14/2022, 9:21 PMAlec Ryan
04/14/2022, 9:23 PMjohann
04/14/2022, 9:24 PMAlec Ryan
04/14/2022, 9:24 PMAlec Ryan
04/14/2022, 9:25 PMAlec Ryan
04/14/2022, 9:25 PM