amazon-kinesis - 在 Kinesis Analytics 应用程序中为流添加恒定值
问题描述
在我的 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"
用一些字符串值替换。原因是我有很多泵写入我的输出流,所以我想要某种指示使用什么泵。有没有办法做到这一点?
解决方案
无论您替换什么"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"
. 要了解有关如何实现此目的的更多信息,请查看有关多值插入语句的文档。
推荐阅读
- bokeh - 如何访问事件数据?
- mysql - 执行任何 DML 操作时如何自动填充日期列
- c# - 使用 UWP 开始 Bass
- node.js - 在运行 mocha 测试之前 Gitlab CI 作业成功
- python - 如何访问 Django ModelAdmin 的 change_list 块内容中的查询集
- ios - 以编程方式快速更改纵横比约束
- azure - ARM 模板:如何引用使用参数设置名称的资源
- java - 是否可以像在 android 中一样为我的应用程序的活动创建一个最近的屏幕
- c# - 使用 PowerShell 向窗口控件发送消息
- angular - 我们可以添加在角度 7 的 index.html 中?