`tests.system.amazon.aws.example_kinesis_analytics`¶

模块内容¶

`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。

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

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

参数

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