Mozilla GCP Ingestion Decoder Module

Maps the GCP Pub/Sub schema back to the original Heka generic ingestion message

1. Decoder Configuration Table -- optional

decoders_moz_ingest_gcp_ingestion = {
    -- validated_stream = false, -- default
}

2. Functions

2.1. decode

Decode and inject the generic ingestion pub/sub message

Arguments

• data (string) - gzipped json
• msg (string) - pub/sub attributes

Return

• none, injects an error message on decode failure

source code: gcp_ingestion.lua