Did I find the right examples for you? yes no

All Samples(8)  |  Call(8)  |  Derive(0)  |  Import(0)
:type aws_access_key_id: string
:param aws_access_key_id: Your AWS Access Key ID

:type aws_secret_access_key: string
:param aws_secret_access_key: Your AWS Secret Access Key

:rtype: :class:`boto.emr.EmrConnection`
:return: A connection to Elastic mapreduce

        def connect_emr(aws_access_key_id=None, aws_secret_access_key=None, **kwargs):
    """
    :type aws_access_key_id: string
    :param aws_access_key_id: Your AWS Access Key ID

    :type aws_secret_access_key: string
    :param aws_secret_access_key: Your AWS Secret Access Key

    :rtype: :class:`boto.emr.EmrConnection`
    :return: A connection to Elastic mapreduce
    """
    from boto.emr import EmrConnection
    return EmrConnection(aws_access_key_id, aws_secret_access_key, **kwargs)
        


src/m/o/moto-HEAD/tests/test_emr/test_emr.py   moto(Download)
def test_create_job_flow():
    conn = boto.connect_emr()
 
    step1 = StreamingStep(
        name='My wordcount example',
def test_create_job_flow_with_new_params():
    # Test that run_jobflow works with newer params
    conn = boto.connect_emr()
 
    conn.run_jobflow(
def test_create_job_flow_visible_to_all_users():
    conn = boto.connect_emr()
 
    job_id = conn.run_jobflow(
        name='My jobflow',
def test_terminate_job_flow():
    conn = boto.connect_emr()
    job_id = conn.run_jobflow(
        name='My jobflow',
        log_uri='s3://some_bucket/jobflow_logs',
def test_add_steps_to_flow():
    conn = boto.connect_emr()
 
    step1 = StreamingStep(
        name='My wordcount example',