enrich
enrich copied to clipboard
snowplow
Snowplow Enrichment jobs and library
Assets refresh is currently configured [with a duration](https://github.com/snowplow/enrich/blob/3.9.0/config/config.kinesis.extended.hocon#L225). Due to auto scaling, it's possible for several instances' assets to be out of sync. To address that a possibility would be...
To maintain compatibility between the Hadoop pipeline (which will continue to use the TSV format for now) and the Kinesis pipeline (which can evolve to using the new Avro format...
As a safeguard, add a timeout to the enriching step. In case of timeout, an `EnrichmentFailures` bad row should be emitted and the event acked.
Usecase: we are using internal API to enrich the event however, sometime, internal apps return 5xxx due to network issue and I could not find retry feature in config. https://github.com/snowplow/enrich/blob/master/config/enrichments/api_request_enrichment_config.json...
Hello, a question about the domain_sessionid UUID validation in the enrich code which created some confusion despite the fact that its described as a text type value in the documentation...
**Project**: snowplow/enricher/common **Version**: master ( latest ) **Expected behavior**: Generate universally unique ID across entire pipeline every time. **Actual behavior**: Generates duplicates event_id columns on enrichment stage **Steps to reproduce**:...
I have seen an example of this exception: ``` ArrayIndexOutOfBoundsException: Index 0 out of bounds for length 0 at com.snowplowanalytics.snowplow.enrich.common.enrichments.web.PageEnrichments$.parseCrossDomain(PageEnrichments.scala:62) at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$.$anonfun$getCrossDomain$1(EnrichmentManager.scala:616) at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$EStateT$.$anonfun$fromEither$1(EnrichmentManager.scala:150) at com.snowplowanalytics.snowplow.enrich.common.enrichments.EnrichmentManager$EStateT$.$anonfun$fromEitherF$1(EnrichmentManager.scala:158) at scala.Function1.$anonfun$andThen$1(Function1.scala:57) ... (20...
For debugging purposes, someone might choose to add some print statements to their custom javascript enrichment: ```js function process(event) { const ipAddress = event.getUser_ipaddress print(ipAddress) return [] } ``` There...