Filebeat - условие kakfka output 'and' или 'regex' не работает - PullRequest
Новая
       174

Filebeat - условие kakfka output 'and' или 'regex' не работает

0 голосов
/ 07 августа 2020

kafka topi c filter filebeat

Привет, я пытаюсь отфильтровать все сообщения, содержащие индикатор TEST01, из разных путей журнала и отправить сообщения в две разные темы (topic1 и topic2) на основе fields.type

Если fields.type равно "first_test", то сообщения должны go переходить к "topic1", а иначе к "topic2". Ниже приведен код, который я пробовал, но операторы и: не работают. Благодарим за любую помощь по кодированию составных условий в выводе filebeat -dynami c kafka. Спасибо https://www.elastic.co/guide/en/beats/filebeat/master/defining-processors.html#condition -равно 

topics:
  - topic: "topic1"
    and:
      - when.contains:
           message: "TEST01"
      - equals:
          fields.type: "first_test"
  - topic: "topic2"
    and:
      - when.contains:
           message: "TEST01"
      - not:
          equals:
            fields.type: "first_test"

1 Ответ

0 голосов
/ 08 августа 2020

Получил эту работу без оператора and:, но с приведенным ниже кодом, используя 'contains' и другие поля. Тем не менее, любые ответы о том, как использовать and: regex в контексте моего вопроса, будут полезны. спасибо 

topics:
  - topic: "topic1"
      - when.contains:
           message: "TEST01"
           fields.type: "first_test"
  - topic: "topic2"
      - when.contains:
           message: "TEST01"
           fields.type: "second_test
...