INSERT - Amazon Kinesis Data Analytics
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

INSERT

INSERT 用于将行插入到流中。它还可在数据泵中使用,用于将一个流的输出插入到另一个流中。

语法

<insert statement> :=   INSERT [ EXPEDITED ]   INTO  <table-name > [ ( insert-column-specification ) ]   <  query  > <insert-column-specification> := < simple-identifier-list > <simple-identifier-list> :=    <simple-identifier> [ , < simple-identifier-list > ]

有关 VALUES 的讨论,请参阅 SELECT 语句

数据泵流插入

INSERT 还可作为 CREATE PUMP 语句的一部分指定。

CREATE PUMP "HighBidsPump" AS INSERT INTO "highBids" ( "ticker", "shares", "price") SELECT  "ticker", "shares", "price" FROM SALES.bids WHERE "shares"*"price">100000

在此处,要插入到“highBids”流中的结果应来自计算结果为流的 UNION ALL 表达式。这将产生持续运行的流插入。插入的行的行时间将继承自来自 select 或 UNION ALL 的行输出的行时间。同样,如果位于此插入器前面的其他插入器已插入行时间晚于此插入器最初准备的行时间的行,则这些行最初可能会被删除,因为后面的行随后将超出时间顺序。请参阅本指南中的主题 CREATE PUMP