in lambda-import-dataset/lambda.py [0:0]
def triggerImport(datasetArn, s3Datasource):
datasetType = datasetArn.split("/")[-1]
response = personalizeClient.create_dataset_import_job(
jobName=datasetType + '-import-' + datetime.datetime.now().strftime('%Y-%m-%d_%H-%M-%S'),
datasetArn=datasetArn,
dataSource={
'dataLocation': s3Datasource
},
roleArn=importRoleArn
)
return response['datasetImportJobArn']