Nifi Processor | PutS3Object

 需求: 從kafka讀取數據,根據內容路由再壓縮後,put 到s3 中。 流程圖。   1、使用Kakfa 讀取數據 2、在RouteTxt 中,根據要求過濾掉不需要的數據 3、在CompressContent 中進行數據壓縮後,流入下一個環節。這裏配置使數據壓縮爲gzip 文件。   4、使用MergeContent ,將數據每 128M合併爲一個塊數據。(注意:雖然MergeContent提
相關文章
相關標籤/搜索