tests.system.amazon.aws.example_kinesis_analytics

属性

ROLE_ARN_KEY

sys_test_context_task

DAG_ID

test_context

test_run

函数

kinesis_analytics_v2_workflow()

copy_jar_to_s3(bucket)

使用 HttpToS3Operator 将应用程序代码复制到 S3。

create_kinesis_stream(stream, region)

创建 kinesis 流并放入一些示例数据。

delete_kinesis_stream(stream, region)

模块内容

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]

使用 HttpToS3Operator 将应用程序代码复制到 S3。

参数:

bucket (str) – Amazon S3 存储桶的名称。

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

创建 kinesis 流并放入一些示例数据。

参数:

  • stream (str) – kinesis 流的名称。

  • region (str) – 区域名称

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

此条目有帮助吗？