Skip to content

Instantly share code, notes, and snippets.

@sangdongvan

sangdongvan/kinesis-analytics-taxi-consumer-infrastructure.yml

Created July 11, 2019 02:42
Show Gist options
  • Save sangdongvan/686d8de0a79bb9a06e6d9c212e6daee3 to your computer and use it in GitHub Desktop.
Save sangdongvan/686d8de0a79bb9a06e6d9c212e6daee3 to your computer and use it in GitHub Desktop.
Download ZIP
excerpt CF setup a flink job in Kinesis Analytics service
Raw
kinesis-analytics-taxi-consumer-infrastructure.yml
KinesisAnalyticsFlinkApplication:
Type: AWS::KinesisAnalyticsV2::Application
Properties:
RuntimeEnvironment: FLINK-1_6
ServiceExecutionRole: !Sub ${KinesisAnalyticsServiceRole.Arn}
ApplicationConfiguration:
ApplicationCodeConfiguration:
CodeContent:
S3ContentLocation:
BucketARN: !Ref FlinkApplicationS3BucketArn
FileKey: !Ref FlinkApplicationS3Path
CodeContentType: ZIPFILE
EnvironmentProperties:
PropertyGroups:
- PropertyGroupId: FlinkApplicationProperties
PropertyMap:
ElasticsearchEndpoint: !Sub https://${ElasticsearchService.DomainEndpoint}
EventTime: true
InputStreamName: !Sub ${KinesisStream}
Region: !Sub ${AWS::Region}
FlinkApplicationConfiguration:
MonitoringConfiguration:
ConfigurationType: CUSTOM
LogLevel: INFO
MetricsLevel: TASK
ApplicationSnapshotConfiguration:
SnapshotsEnabled: true
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment