타임 스탬프가 포함 된 흐름 파일 수정

장치에서 Apache-nifi 프로세서로 비디오 데이터가 전송됩니다.이 흐름 파일에 타임 스탬프를 추가하고 Kafka 프로세서를 사용하여 Kafka에 저장하려고합니다. 가장 좋은 방법은 무엇입니까?타임 스탬프가 포함 된 흐름 파일 수정

2016-10-24 jon

UpdateAttribute 프로세서를 사용하고 표현식 언어 표현 ${now():toNumber()}을 사용하여 현재 시간을 밀리 초 단위로 표현하고 이것을 플로우 파일에 속성으로 추가 할 수 있습니다. 그런 다음 PutKafka에 연결할 수 있습니다.

2016-10-24 04:46:37 Andy

Andy가 말했던 것 외에도, 아는 한 Kafka에는 각 메시지에 헤더 특성이 없으므로 타임 스탬프 + 비디오를 카프카에 전달하는 유일한 방법은 카프카를 넣는 것입니다. 페이로드에 타임 스탬프를 넣으면 더 이상 유효하지 않은 비디오가됩니다. –

답변