如何在 Kinesis Analytics SQL 查询中解析 Json

Question

如何在 Kinesis Analytics SQL 查询中解析 Json。

我从 Kinesis Stream 接收到流数据，在列中我有 json 想要准备 Json 的一些元素

例如。在列体中，我有下面的 Json

{"deviceStatus":"Active", "deviceId":"11111"}

我想从 json 中提取 deviceStatus，如下所示

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( "deviceStatus" VARCHAR(24));
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
INSERT INTO "DESTINATION_SQL_STREAM" 
SELECT STREAM "body"."deviceStatus" FROM "SOURCE_SQL_STREAM_001";

Answer 1

我生成了一个包含 2 列的架构 - 设备状态 - 设备ID

我将每个 json 元素映射到每个列，如下文所述。

https://docs.aws.amazon.com/kinesisanalytics/latest/dev/sch-mapping.html#sch-mapping-json

https://docs.aws.amazon.com/kinesisanalytics/latest/dev/about-json-path.html

并在下面的 SQL 查询中使用它们

 CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( "deviceId" VARCHAR(16), "deviceStatus" VARCHAR(24));
 CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
 INSERT INTO "DESTINATION_SQL_STREAM" 
 SELECT STREAM "deviceId", "deviceStatus" FROM "SOURCE_SQL_STREAM_001";