Menu
Amazon Kinesis Data Analytics
SQL Reference

REGEX_LOG_PARSE

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

Parses a character string based on Java Regular Expression patterns as defined in java.util.regex.pattern.

Columns are based on match groups defined in the regex-pattern. Each group defines a column, and the groups are processed from left to right. Failure to match produces a NULL value result: If the regular expression does not match the string passed as the first parameter, NULL is returned.

The columns returned will be COLUMN1 through COLUMNn, where n is the number of groups in the regular expression. The columns will be of type varchar(1024).

Examples

Example Dataset

The examples following are based on the sample stock dataset that is part of the Getting Started Exercise in the Amazon Kinesis Analytics Developer Guide. To run each example, you need an Amazon Kinesis Analytics application that has the sample stock ticker input stream. To learn how to create an Analytics application and configure the sample stock ticker input stream, see the Getting Started Exercise in the Amazon Kinesis Analytics Developer Guide.

The sample stock dataset has the schema following.

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

Example 1: Return results from two capture groups

The following code example searches the contents of the sector field for a letter E and the character that follows it, and then searches for a letter R, and returns it and all characters following it:

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;

The preceding code example produces results similar to the following:

Example 2: Return a stream field and results from two capture groups

The following code example returns the sector field, and searches the contents of the sector field for a letter E and returns it and the character that follows it, and then searches for a letter R, and returns it and all characters following it:

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;

The preceding code example produces results similar to the following:

For more information, see FAST_REGEX_LOG_PARSER.

Quick Regex Reference

For full details on Regex, see java.util.regex.pattern

[xyz] Find single character of: x, y or z

[^abc] Find any single character except: x, y, or z

[r-z] Find any single character between r-z

[r-zR-Z] Find any single character between r-z or R-Z

^ Start of line

$ End of line

\A Start of string

\z End of string

. Any single character

\s Find any whitespace character

\S Find any non-whitespace character

\d Find any digit

\D Find any non-digit

\w Find any word character (letter, number, underscore)

\W Find any non-word character

\b Find any word boundary

(...) Capture everything enclosed

(x|y) Find x or y (also works with symbols such as \d or \s)

x? Find zero or one of x (also works with symbols such as \d or \s)

x* Find zero or more of x (also works with symbols such as \d or \s)

x+ Find one or more of x (also works with symbols such as \d or \s)

x{3} Find exactly 3 of x (also works with symbols such as \d or \s)

x{3,} Find 3 or more of x (also works with symbols such as \d or \s)

x{3,6} Find between 3 and 6 of x (also works with symbols such as \d or \s)