在 Kinesis Analytics 应用程序中向流添加常量值

Question

在我的 Kinesis Analytics 应用程序中，我想向输出流添加一个常量字符串。

例如：

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
            "constant_column"  varchar(100),
            "feature" varchar(246)
            );

CREATE OR REPLACE PUMP "OutputPump" AS 
   INSERT INTO "DESTINATION_SQL_STREAM" 
      SELECT STREAM   "MY_CONSTANT_STRING", "SOURCE_SQL_STREAM_001"."feature"
      FROM   "SOURCE_SQL_STREAM_001";

我想用一些字符串值替换"MY_CONSTANT_STRING"。这样做的原因是我有很多泵写入我的输出流，所以我想要某种指标，使用什么泵。有没有办法做到这一点？

Answer 1

无论您用什么替换"MY_CONSTANT_STRING"都应该是 "SOURCE_SQL_STREAM_001" 中的列名。很难从你的问题中看出，但这似乎应该是"constant_column".

您也可以将"SOURCE_SQL_STREAM_001"."feature"替换为 仅"feature" .

因此，最后两行应该是：

SELECT STREAM   "constant_column", "feature"
      FROM   "SOURCE_SQL_STREAM_001";

如果要添加不是来自"SOURCE_SQL_STREAM_001"的自定义字符串，则需要在这两行之前/之后添加此字符串，并用括号分隔自定义字符串和 select 语句。不应将此字符串放在"MY_CONSTANT_STRING"的位置，因为该字段是 select 语句的一部分，该语句纯粹用于从 "SOURCE_SQL_STREAM_001" 中提取列。若要了解有关如何实现此目的的更多信息，请查看有关多值插入语句的文档。