タイムスタンプでフローファイルを変更する

Question

デバイスからApache-nifiプロセッサにビデオデータが送られています。このフローファイルにタイムスタンプを追加し、カフカプロセッサを使用してKafkaに保存します。何が最善の方法ですか？

Answer 1

UpdateAttributeプロセッサを使用し、式言語式${now():toNumber()}を使用して、現在の時刻をミリ秒単位で表し、これをフローファイルに属性として追加することができます。 PutKafkaにルーティングできます。