Some logs from Azure can have issues with newlines while others with single quotes.
A method had to be created to internally fix this in beats. Otherwise this issue could lead to failure in processing the data.
(ex: the pipeline receiving one document with two records).
Malformed logs journey in the Elastic stack
1) Examples of malformed JSONs
1) Live demo with how a malformed log looks like in Kibana
2) Deep dive into beats code failure where the malformed logs end up from azureeventhub.
Challenge: Spin up the stack using a custom version of beats
Why was creating a custom beats needed to properly test sanitization E2E?
Overview of issue
Some logs from Azure can have issues with newlines while others with single quotes.
A method had to be created to internally fix this in beats. Otherwise this issue could lead to failure in processing the data. (ex: the pipeline receiving one document with two records).
Malformed logs journey in the Elastic stack
1) Examples of malformed JSONs
1) Live demo with how a malformed log looks like in Kibana
2) Deep dive into beats code failure where the malformed logs end up from
azureeventhub
.Challenge: Spin up the stack using a custom version of beats
Why was creating a custom beats needed to properly test sanitization E2E?
Set up the custom agent live with filebeat modifications: https://github.com/zmoog/public-notes/issues/35
Talk about challenges/limitations while setting it up.
Code dive: Sanitization implementation in beats using Go
Code walkthrough and logic used explained
Tradeoff in complexity vs addressing as many malformation cases explained with different approaches: https://go.dev/play/p/wCNCM7-QM9A
Elastic agent sample configuration for integrations (explain how everything works together).
E2E testing
Brief overview of
eh
library by Maurizio https://github.com/zmoog/eventhubsFull E2E testing of sanitization using different types of malformed logs sent via
eh
and an Azure integrationSanitization UI in Kibana
Discuss implementation and code walkthrough
Live test using an Azure integration and
eh