AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource - AWS CloudFormation
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource

将引用数据源添加到现有的基于 SQL 的 Kinesis Data Analytics 应用程序。

Kinesis Data Analytics 读取参考数据(即 Amazon S3 对象),并在应用程序中创建应用程序内部表。在请求中,您提供源(S3 存储桶名称和对象键名称)、要创建的应用程序内部表的名称,以及描述 Amazon S3 对象中的数据如何映射到所生成应用程序内部表中的列的必要映射信息。

语法

要在 AWS CloudFormation 模板中声明此实体,请使用以下语法:

JSON

{ "Type" : "AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource", "Properties" : { "ApplicationName" : String, "ReferenceDataSource" : ReferenceDataSource } }

YAML

Type: AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource Properties: ApplicationName: String ReferenceDataSource: ReferenceDataSource

属性

ApplicationName

应用程序名称。

必需:是

类型:字符串

最低1

最高128

模式[a-zA-Z0-9_.-]+

Update requires: Replacement

ReferenceDataSource

对于基于 SQL 的 Kinesis Data Analytics 应用程序,描述引用数据源,方式是提供源信息(Amazon S3 存储桶名称和对象键名称)、创建的结果应用程序内部表名称以及要将 Amazon S3 对象中的对象元素映射到应用程序内部表的所需架构。

必需:是

类型ReferenceDataSource

Update requires: No interruption

示例

创建 ApplicationReferenceDataSource 资源

JSON

{ "ApplicationReferenceDataSource": { "Type": "AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource", "Properties": { "ApplicationName": { "Ref": "BasicApplication" }, "ReferenceDataSource": { "TableName": "exampleTable", "ReferenceSchema": { "RecordColumns": [ { "Name": "example", "SqlType": "VARCHAR(16)", "Mapping": "$.example" } ], "RecordFormat": { "RecordFormatType": "JSON", "MappingParameters": { "JSONMappingParameters": { "RecordRowPath": "$" } } } }, "S3ReferenceDataSource": { "BucketARN": { "Fn::GetAtt": [ "S3Bucket", "Arn" ] }, "FileKey": "fakeKey" } } } } }

YAML

ApplicationReferenceDataSource: Type: 'AWS::KinesisAnalyticsV2::ApplicationReferenceDataSource' 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

另请参阅