メニュー
AWS CloudFormation
ユーザーガイド (API Version 2010-05-15)

AWS::KinesisAnalytics::Application

AWS::KinesisAnalytics::Application リソースによって Amazon Kinesis Analytics アプリケーションが作成されます。詳細については、「Amazon Kinesis Analytics 開発者ガイド」を参照してください。

構文

AWS CloudFormation テンプレートでこのエンティティを宣言するには、次の構文を使用します。

JSON

Copy
{ "Type" : "AWS::KinesisAnalytics::Application", "Properties" : { "ApplicationName" : String, "ApplicationDescription" : String, "ApplicationCode" : String, "Inputs" : [ Input, ... ] } }

YAML

Copy
Type: "AWS::KinesisAnalytics::Application" Properties: ApplicationName: String ApplicationDescription: String ApplicationCode: String Inputs: - Input

プロパティ

ApplicationName

Amazon Kinesis Analytics アプリケーションの名前。

必須: いいえ

タイプ: 文字列

更新に伴う要件: 置換。

ApplicationDescription

アプリケーションの簡単な説明。

必須: いいえ

タイプ: 文字列

更新に伴う要件: 中断はありません。

ApplicationCode

入力データを読み取って変換し、出力を生成する 1 つ以上の SQL ステートメント。

必須: いいえ

タイプ: 文字列

更新に伴う要件: 中断はありません。

Inputs

このパラメータを使用して、アプリケーション入力を設定します。

必須: はい

: Kinesis Analytics アプリケーション入力 のリスト

更新に伴う要件: 中断はありません。

Amazon Kinesis Analytics アプリケーションを作成する

次の例では、Kinesis Analytics アプリケーションの作成方法と設定方法について説明します。

YAML

Copy
--- Description: "Sample KinesisAnalytics via CloudFormation" Resources: BasicApplication: Type: "AWS::KinesisAnalytics::Application" Properties: ApplicationName: "sampleApplication" ApplicationDescription: "SampleApp" ApplicationCode: "Example Application Code" Inputs: - NamePrefix: "exampleNamePrefix" InputSchema: RecordColumns: - Name: "example" SqlType: "VARCHAR(16)" Mapping: "$.example" RecordFormat: RecordFormatType: "JSON" MappingParameters: JSONMappingParameters: RecordRowPath: "$" KinesisStreamsInput: ResourceARN: !GetAtt InputKinesisStream.Arn RoleARN: !GetAtt KinesisAnalyticsRole.Arn InputKinesisStream: Type: "AWS::Kinesis::Stream" Properties: ShardCount: 1 KinesisAnalyticsRole: Type: "AWS::IAM::Role" Properties: AssumeRolePolicyDocument: Version: "2012-10-17" Statement: - Effect: Allow Principal: Service: kinesisanalytics.amazonaws.com Action: "sts:AssumeRole" Path: "/" Policies: - PolicyName: Open PolicyDocument: Version: "2012-10-17" Statement: - Effect: Allow Action: "*" Resource: "*" BasicApplicationOutputs: Type: "AWS::KinesisAnalytics::ApplicationOutput" DependsOn: BasicApplication Properties: ApplicationName: !Ref BasicApplication Output: Name: "exampleOutput" DestinationSchema: RecordFormatType: "CSV" KinesisStreamsOutput: ResourceARN: !GetAtt OutputKinesisStream.Arn RoleARN: !GetAtt KinesisAnalyticsRole.Arn OutputKinesisStream: Type: "AWS::Kinesis::Stream" Properties: ShardCount: 1 ApplicationReferenceDataSource: Type: "AWS::KinesisAnalytics::ApplicationReferenceDataSource" DependsOn: BasicApplicationOutputs Properties: ApplicationName: !Ref BasicApplication ReferenceDataSource: TableName: "exampleTable" ReferenceSchema: RecordColumns: - Name: "example" SqlType: "VARCHAR(16)" Mapping: "$.example" RecordFormat: RecordFormatType: "JSON" MappingParameters: JSONMappingParameters: RecordRowPath: "$" S3ReferenceDataSource: BucketARN: !GetAtt S3Bucket.Arn FileKey: 'fakeKey' ReferenceRoleARN: !GetAtt KinesisAnalyticsRole.Arn S3Bucket: Type: AWS::S3::Bucket Outputs: ApplicationPhysicalResourceId: Value: !Ref BasicApplication

このページの内容: