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

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

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 > ]

有关价值观的讨论,请参见SELECT.

泵流插入

也可以将 INSERT 指定为创建转储语句。

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 输出的行的行时间。同样,如果其他插入器在此插入器之前插入的行时间晚于该插入器最初准备的行,则最初可能会删除行,因为后者会出现时间不合时宜。参见主题创建转储