logstash 필터로 json 입력을 변환하십시오.

Question

Kafka 파이프를 통해 logstash에 대한 입력이 표시됩니다. 정상적으로 작동합니다. 이 스트림에서 가장 관련 데이터가 키바에서 사용하기 위해 다음과 같은 형식

{data: [ 
    { 
     name: 'fieldname1', 
     value: 'value1' 
    }, 
    { 
     name: 'fieldname2', 
     value: 'value2' 
    }, 
    .. 
]} 

에, 나는

{data: { 
    'fieldname1': 'value1', 
    'fieldname2': 'value2' 
}} 

에 그 변환하는 일을 간단한 방법이 필요로하는 루비 필터 외에 플러그인?

Answer 1

Baudsp가 맞습니다. 데이터 배열의 크기가 고정되어 있지 않으면 logstash에 반복 기능이 없으므로이를 수행 할 방법이 없습니다.

또는 자신 만의 변형 플러그인을 작성할 수도 있지만 과도 함일 수 있습니다 (본질적으로 루비 코드이기도합니다).