args2 = ['s3://us-east-1.elasticmapreduce/libs/hive/hive-script',
    '--base-path', 's3://us-east-1.elasticmapreduce/libs/hive/',
    '--hive-versions', '0.7', '--run-hive-script', '--args', '-f',
    s3_query_file_uri]
steps = []
for name, args in zip(('Setup Hive', 'Run Hive Script'), (args1, args2)):
    step = JarStep(name,
        's3://us-east-1.elasticmapreduce/libs/script-runner/script-runner.jar',
        step_args=args)
steps.append(step)
jobid = EmrConnection().run_jobflow(name, s3_log_uri, steps=steps,
    master_instance_type=master_instance_type, slave_instance_type=
    slave_instance_type, num_instances=num_instances, hadoop_version='0.20')
Поддержка клиента Python для запуска Hive поверх Amazon EMR