Skip to content

Instantly share code, notes, and snippets.

@krogebry
Last active November 11, 2020 18:20
Show Gist options
  • Save krogebry/24334855f2a729ee0bf0454e377f0607 to your computer and use it in GitHub Desktop.
Save krogebry/24334855f2a729ee0bf0454e377f0607 to your computer and use it in GitHub Desktop.
Telemetry postgres
apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow
metadata:
name: renovo-logging-telemetry-postgres-rbatch
spec:
filters:
- grep:
regexp:
- key: "$.kubernetes.container_name"
pattern: /telemetry-postgres/
- key: "$.log"
pattern: /^Received\sbatch/
- parser:
key_name: "$.log"
hash_value_field: telemetry_postgres
emit_invalid_record_to_error: true
reserve_data: true
parse:
type: multi_format
patterns:
- format: regexp
types: batch_id:string,size:integer,queue:string,target:string
expression: |
/^Received batch (?<batch_id>[^ ]*) of size (?<size>[^ ]*) from (?<queue>[^ ]*) for (?<target>[^ ]*)$/
- format: regexp
types: batch_id:string,size:integer,queue:string
expression: |
/^Received batch (?<batch_id>[^ ]*) of size (?<size>[^ ]*) from (?<queue>[^ ]*)$/
- dedot:
de_dot_separator: "-"
de_dot_nested: true
globalOutputRefs: []
localOutputRefs:
- logging-out
match:
- select: {}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment