CREATE STREAM - Amazon Kinesis Data Analytics
未分析的日志数据的简单流从 Intelligent Travel System 管道捕获传感器数据的流从电子商务管道捕获订单数据的流
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';