Elasticsearch Encoder for Mozilla Telemetry Messages
1. Encoder Configuration Table
encoders_elasticsearch_common = {
-- Common Options
-- Array of Heka message field names that should be passed to Elasticsearch.
fields = {"Payload", "Fields[docType]"} -- required
}
2. Functions
2.1. encode
Encodes a Heka Mozilla telemetry message into an ElasticSearch Bulk Load JSON schema.
Arguments
- none
Return
- JSON (string)
source code: telemetry.lua