from airflow.providers.amazon.aws.operators.glue import AwsGlueJobOperator
job_operator = AwsGlueJobOperator( job_name='my_glue_job', aws_conn_id='aws_default' )
import boto3
glue = boto3.client('glue')
response = glue.create_job( Name='my_glue_job', Role='my_glue_role', Command={ 'Name': 'glueetl', 'ScriptLocation': 's3://my-bucket/glue-script.py' }, DefaultArguments={ '--job-bookmark-option': 'job-bookmark-enable', '--enable-metrics': '' }, WorkerType='G.1X', NumberOfWorkers=10 )
import boto3
glue = boto3.client('glue')
response = glue.start_job_run( JobName='my_glue_job', Arguments={ '--job-bookmark-option': 'job-bookmark-enable', '--enable-metrics': '' }, WorkerType='G.1X', NumberOfWorkers=10 )