我正在调用dynamoDBTrigger. 此流被配置为 kinesis 分析应用程序的输入流。我在 kinesis 流上配置了一个 lambda 预处理器，用于记录写入流中的数据。但是，在源选项卡的分析应用程序窗口中，会出现消息源流中没有行。这些行不在应用程序内的 sql 流中创建。
我正在使用 Node 并使用serverless.yml文件部署服务。以下是配置 -
RecordKinesisAnalyticsApp:
Type: AWS::KinesisAnalytics::Application
Properties:
ApplicationName: RecordKinesisAnalyticsApp
ApplicationDescription: RecordKinesisAnalyticsApp
ApplicationCode: ${file(./serverless/metadataQueries.yml):AnalyticsQuery_1}
Inputs:
- NamePrefix: "RecordPrefix"
InputSchema:
RecordColumns:
- Name: "USER_ID"
SqlType: "VARCHAR(20)"
Mapping: "$._userId"
- Name: "ANXIETY"
SqlType: "INTEGER"
Mapping: "$.anxiety"
RecordEncoding: "UTF-8"
RecordFormat:
RecordFormatType: "JSON"
KinesisStreamsInput:
ResourceARN:
Fn::GetAtt:
- RecordKinesisInputStream
- Arn
RoleARN: arn:aws:iam::xxxxxxxxxxx:role/service-role/kinesis-analytics-KinesisDemo-us-east-1
这是分析查询 -
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM " (USER_ID VARCHAR(20), ANXIETY INTEGER);
CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM USER_ID, ANXIETY
FROM "RecordPrefix_001"
WHERE ANXIETY >= 0;
