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

CREATE STREAM

CREATE STREAM 语句创建一个(本地)流。 此流的名称必须与同一架构中的任何其他流的名称不同。好的做法是包含流的描述。

与表类似,流也具有列,并且您可以在 CREATE STREAM 语句中指定这些列的数据类型。这些列应映射到您为其创建流的数据源。对于 column_name,可使用任何有效的非预留 SQL 名称。列值不能为 null。

  • 指定 OR REPLACE 会重新创建流 (如果流已存在),启用对现有对象的定义更改,隐式删除它,而无需首先使用 DRP 命令。在具有正在传送的数据的流上使用 CREATE OR REPLACE 将终止流并丢失所有历史记录。

  • 只有在指定 OR REPLACE 后才能指定 RENAME。

  • 有关采用 type_specification 的类型和值的完整列表(如 TIMESTAMP、INTEGER 或 varchar(2)),请参阅《Amazon Kinesis Data Analytics SQL 参考指南》中的主题“Amazon Kinesis Data Analytics 数据类型”。

  • 对于 option_value,可使用任何字符串。

未分析的日志数据的简单流

CREATE OR REPLACE STREAM logStream (    source  VARCHAR(20),    message VARCHAR(3072)) DESCRIPTION 'Head of webwatcher stream processing';

从 Intelligent Travel System 管道捕获传感器数据的流

CREATE OR REPLACE STREAM "LaneData" (    -- ROWTIME is time at which sensor data collected    LDS_ID  INTEGER,        -- loop-detector ID    LNAME   VARCHAR(12),    LNUM    VARCHAR(4),    OCC     SMALLINT,    VOL     SMALLINT,    SPEED   DECIMAL(4,2) ) DESCRIPTION 'Conditioned LaneData for analysis queries';

从电子商务管道捕获订单数据的流

CREATE OR REPLACE STREAM "OrderData" (    "key_order"    BIGINT NOT NULL,    "key_user"     BIGINT,    "country"      SMALLINT,    "key_product"  INTEGER,    "quantity"     SMALLINT,    "eur"          DECIMAL(19,5),    "usd"          DECIMAL(19,5) ) DESCRIPTION 'conditioned order data, ready for analysis';