import boto3 from botocore.exceptions import ClientError from dejavu import Dejavu import config BUCKET = 'dev-orcd-raw-assets' JOB_QUEUE = 'arn:aws:batch:us-east-1:103233932089:job-queue/dev-fingerprinting-batch-queue' JOB_DEFINITION = 'dev-fingerprinting-generator-job' batch = boto3.client('batch') if __name__ == '__main__': djv = Dejavu(config.DB_CONFIG) djv.load_fingerprinted_filenames() prefix = 'WAV21/704417/634/7044176340099/' f = '7044176340099_1_1' k = '{}{}.{}'.format(prefix, f, 'wav') if f not in djv.filenames: try: response = batch.submit_job( jobName='generate-{}'.format(f), jobQueue=JOB_QUEUE, jobDefinition=JOB_DEFINITION, parameters={ 'S3bucket': BUCKET, 'S3key': k } ) print(response) except ClientError as e: print(e)