REGEX_LOG_PARSE - Amazon Kinesis Data Analytics

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

REGEX_LOG_PARSE

REGEX_LOG_PARSE (<character-expression>,<regex-pattern>,<columns>)<regex-pattern> := <character-expression>[OBJECT] <columns> := <columnname> [ <datatype> ] {, <columnname> <datatype> }*

基于 java.util.regex.pattern 中定义的 Java 正则表达式模式解析字符串。

列基于正则表达式模式中定义的匹配组。每个组定义一列,这些组是从左到右处理的。不匹配会产生空值结果:如果正则表达式与作为第一个参数传递的字符串不匹配,则返回 NULL。

返回的列将是 ColumnN 中的 COLUMN1,其中 n 是正则表达式中的组数。这些列的类型将为 varchar (1024)。

示例

示例数据集

以下示例基于样本库存数据集,该数据集是 Amazon Kinesis Analytics 开发人员指南入门练习的一部分。要运行每个示例,您需要一个包含样本股票行情输入流的 Amazon Kinesis Analytics 应用程序。要了解如何创建 Analytics 应用程序和配置示例股票代码输入流,请参阅《Amazon Kinesis Analytics 开发人员指南》 中的入门练习

具有以下架构的示例股票数据集。

(ticker_symbol VARCHAR(4), sector VARCHAR(16), change REAL, price REAL)

示例 1:从两个捕获组返回结果

以下代码示例搜索 sector 字段的内容以查找字母 E 及其后面的字符,然后搜索字母 R,并返回该字母及其后面的所有字符:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (match1 VARCHAR(1024), match2 VARCHAR(1024)); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM T.REC.COLUMN1, T.REC.COLUMN2 FROM (SELECT STREAM SECTOR, REGEX_LOG_PARSE(SECTOR, '.*([E].).*([R].*)') AS REC FROM SOURCE_SQL_STREAM_001) AS T;

前面的代码示例生成类似于以下内容的结果:

Table showing ROWTIME, MATCH1, and MATCH2 columns with sample data entries.

示例 2:从两个捕获组返回一个流字段和结果

以下代码示例返回 sector 字段,搜索 sector 字段的内容以查找字母 E 并返回此字母及其后面的字符,然后搜索字母 R,并返回该字母及其后面的所有字符:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (sector VARCHAR(24), match1 VARCHAR(24), match2 VARCHAR(24)); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM T.SECTOR, T.REC.COLUMN1, T.REC.COLUMN2 FROM (SELECT STREAM SECTOR, REGEX_LOG_PARSE(SECTOR, '.*([E].).*([R].*)') AS REC FROM SOURCE_SQL_STREAM_001) AS T;

前面的代码示例生成类似于以下内容的结果:

Table showing data entries for ROWTIME, SECTOR, MATCH1, and MATCH2 columns with healthcare and energy sectors.

有关更多信息,请参阅FAST_REGEX_LOG_PARSER

使用进行长度

有关正则表达式的完整详细信息,请参阅 java.util.regex.pattern

[xyz] 查找 x、y 或 z 的单个字符

[^abc] 查找除了 x、y 或 z 之外的任何单个字符

[r-z] 查找 r-z 之间的任何单个字符

[r-zr-z] 查找 r-z 或 R-Z 之间的任何单个字符

^ 行首

$ 行尾

\ A 字符串的开头

\ z 字符串结尾

。 任何单个字符

\ s 查找任何空格字符

\ S 查找任何非空格字符

\ d 查找任意数字

\ D 查找任何非数字

\ w 查找任何单词字符(字母、数字、下划线)

\ W 查找任何非单词字符

\ b 找到任何单词边界

(...) 捕捉随附的所有内容

(x|y) 查找 x 或 y(也适用于诸如\ d 或\ s 之类的符号)

x? 找到 x 中的零或一(也适用于诸如\ d 或\ s 之类的符号)

x* 查找 x 的零个或多个(也适用于诸如\ d 或\ s 之类的符号)

x+ 查找 x 中的一个或多个(也适用于诸如\ d 或\ s 之类的符号)

x {3} 精确找到 x 中的 3 个(也适用于诸如\ d 或\ s 之类的符号)

x {3,} 查找 x 中的 3 个或更多(也适用于\ d 或\ s 等符号)

x {3,6} 在 x 的 3 到 6 之间查找(也适用于\ d 或\ s 等符号)