Gems/AWSMetrics/cdk/aws_metrics/aws_metrics_constants.py [9:38]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
APIGATEWAY_STAGE = "api"


# Constants for Kinesis Data Analytics application
# The SQL code for the Kinesis analytics application.
KINESIS_APPLICATION_CODE = "-- ** Continuous Filter **\n"\
                   "CREATE OR REPLACE STREAM \"DESTINATION_STREAM\" (\n"\
                   "METRIC_NAME VARCHAR(1024),\n"\
                   "METRIC_TIMESTAMP BIGINT,\n"\
                   "METRIC_UNIT_VALUE_INT BIGINT,\n"\
                   "METRIC_UNIT VARCHAR(1024),\n"\
                   "OUTPUT_TYPE VARCHAR(1024));\n"\
                   "CREATE OR REPLACE PUMP \"LOGIN_PUMP\" AS\n"\
                   "INSERT INTO \"DESTINATION_STREAM\" (METRIC_NAME, METRIC_TIMESTAMP, METRIC_UNIT_VALUE_INT, METRIC_UNIT, OUTPUT_TYPE)\n"\
                   "SELECT STREAM 'TotalLogins', UNIX_TIMESTAMP(TIME_WINDOW), COUNT(distinct_stream.login_count) AS unique_count, 'Count', 'metrics'\n"\
                   "FROM (\n"\
                   "    SELECT STREAM DISTINCT\n"\
                   "    ROWTIME as window_time,\n"\
                   "    \"AnalyticsApp_001\".\"event_id\" as login_count,\n"\
                   "    STEP(\"AnalyticsApp_001\".ROWTIME BY INTERVAL '1' MINUTE) as TIME_WINDOW\n"\
                   "    FROM \"AnalyticsApp_001\"\n"\
                   "    WHERE \"AnalyticsApp_001\".\"event_name\" = 'login'\n"\
                   ") as distinct_stream\n"\
                   "GROUP BY\n"\
                   "    TIME_WINDOW,\n"\
                   "    STEP(distinct_stream.window_time BY INTERVAL '1' MINUTE);\n"


# Constants for the analytics processing and events processing lambda.
LAMBDA_TIMEOUT_IN_MINUTES = 5
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



Gems/AWSMetrics/cdv1/aws_metrics/aws_metrics_constants.py [9:38]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
APIGATEWAY_STAGE = "api"


# Constants for Kinesis Data Analytics application
# The SQL code for the Kinesis analytics application.
KINESIS_APPLICATION_CODE = "-- ** Continuous Filter **\n"\
                   "CREATE OR REPLACE STREAM \"DESTINATION_STREAM\" (\n"\
                   "METRIC_NAME VARCHAR(1024),\n"\
                   "METRIC_TIMESTAMP BIGINT,\n"\
                   "METRIC_UNIT_VALUE_INT BIGINT,\n"\
                   "METRIC_UNIT VARCHAR(1024),\n"\
                   "OUTPUT_TYPE VARCHAR(1024));\n"\
                   "CREATE OR REPLACE PUMP \"LOGIN_PUMP\" AS\n"\
                   "INSERT INTO \"DESTINATION_STREAM\" (METRIC_NAME, METRIC_TIMESTAMP, METRIC_UNIT_VALUE_INT, METRIC_UNIT, OUTPUT_TYPE)\n"\
                   "SELECT STREAM 'TotalLogins', UNIX_TIMESTAMP(TIME_WINDOW), COUNT(distinct_stream.login_count) AS unique_count, 'Count', 'metrics'\n"\
                   "FROM (\n"\
                   "    SELECT STREAM DISTINCT\n"\
                   "    ROWTIME as window_time,\n"\
                   "    \"AnalyticsApp_001\".\"event_id\" as login_count,\n"\
                   "    STEP(\"AnalyticsApp_001\".ROWTIME BY INTERVAL '1' MINUTE) as TIME_WINDOW\n"\
                   "    FROM \"AnalyticsApp_001\"\n"\
                   "    WHERE \"AnalyticsApp_001\".\"event_name\" = 'login'\n"\
                   ") as distinct_stream\n"\
                   "GROUP BY\n"\
                   "    TIME_WINDOW,\n"\
                   "    STEP(distinct_stream.window_time BY INTERVAL '1' MINUTE);\n"


# Constants for the analytics processing and events processing lambda.
LAMBDA_TIMEOUT_IN_MINUTES = 5
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -