def triggerImport()

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']