2

在我的 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"用一些字符串值替换。原因是我有很多泵写入我的输出流，所以我想要某种指示使用什么泵。有没有办法做到这一点？

4

1 回答 1

0

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

您也可以替换"SOURCE_SQL_STREAM_001"."feature"为 just "feature"。

所以，你的最后两行应该是：

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

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

于 2019-07-22T14:27:30.233 回答