Overview
This node parses Snowplow analytics data. It processes incoming items, attempting to transform the 'message' field in each item's JSON data using the Snowplow analytics SDK. If the 'message' is a string, it transforms it into a structured format; if it's already an object, it assigns it directly. This node is useful for workflows that need to interpret and work with Snowplow event data, such as analytics pipelines or data enrichment processes.
Use Case Examples
- Transform raw Snowplow event messages into structured JSON for further processing.
- Parse Snowplow data streams to extract event details for analytics dashboards.
Output
JSON
json- The transformed or parsed Snowplow event data as JSON.
Dependencies
- snowplow-analytics-sdk
Troubleshooting
- If the 'message' field is missing or not a string/object, the node may throw an error.
- Errors during transformation will either stop execution or be added to the output if 'Continue On Fail' is enabled.
- Ensure the input data contains a 'message' property with valid Snowplow event data in string or object form.