tests.system.amazon.aws.example_kinesis_analytics

Attributes

ROLE_ARN_KEY

sys_test_context_task

DAG_ID

test_context

test_run

Functions

kinesis_analytics_v2_workflow()

copy_jar_to_s3(bucket)

Copy application code to S3 using HttpToS3Operator.

create_kinesis_stream(stream, region)

Create kinesis stream and put some sample data.

delete_kinesis_stream(stream, region)

Module Contents

tests.system.amazon.aws.example_kinesis_analytics.ROLE_ARN_KEY = 'ROLE_ARN'[source]
tests.system.amazon.aws.example_kinesis_analytics.sys_test_context_task[source]
tests.system.amazon.aws.example_kinesis_analytics.DAG_ID = 'example_kinesis_analytics'[source]
tests.system.amazon.aws.example_kinesis_analytics.kinesis_analytics_v2_workflow()[source]
tests.system.amazon.aws.example_kinesis_analytics.copy_jar_to_s3(bucket)[source]

Copy application code to S3 using HttpToS3Operator.

Parameters:

bucket (str) – Name of the Amazon S3 bucket.

tests.system.amazon.aws.example_kinesis_analytics.create_kinesis_stream(stream, region)[source]

Create kinesis stream and put some sample data.

Parameters:

  • stream (str) – Name of the kinesis stream.

  • region (str) – Region name

tests.system.amazon.aws.example_kinesis_analytics.delete_kinesis_stream(stream, region)[source]
tests.system.amazon.aws.example_kinesis_analytics.test_context = None[source]
tests.system.amazon.aws.example_kinesis_analytics.test_run[source]

Was this entry helpful?