datax插件開發(fā)的指南(編輯修改稿)
2025-05-03 00:35 本頁面
【文章內(nèi)容簡介】 插件開發(fā)過程。 二、 Reader插件開發(fā)（以reader為例） 確定插件所需配置的參數(shù) 確定插件參數(shù)，創(chuàng)建靜態(tài)類HttpReader，尤其注意對參數(shù)的注釋盡量參照源碼規(guī)范，DataX運(yùn)行時，如圖：圖 1 構(gòu)建相應(yīng)包和類結(jié)構(gòu) ，再在reader包下創(chuàng)建類HttpReader，.圖 2圖 3 實現(xiàn)重載方法 獲得圖3所示效果：現(xiàn)在開始分別實現(xiàn)init( ), connectToDb( ), startRead(LineSender sender), finish( ) 四個方法。（1） Init( )：通過從Reader間接繼承自DefaultPlugin的PluginParam類型的參數(shù)param獲取配置reader插件的參數(shù)(此處可以對參數(shù)進(jìn)行檢查和格式處理等操作)，如圖：圖 4（2） connectToDb( ): 本插件不需要此操作，函數(shù)為空實現(xiàn)。（在數(shù)據(jù)庫相關(guān)插件中，(keyId)獲取connection），如在mysqlreader中，該函數(shù)為：圖 5（3） startRead(LineSender sender)：根據(jù)init( )初始化的參數(shù)，連接相應(yīng)的 URL, 獲取其中數(shù)據(jù)并用BufferedReader封裝，循環(huán)處理每行數(shù)據(jù)，() 產(chǎn)生line，(fieldStr)把每行數(shù)據(jù)切分成字段后組裝成Line中的field,(line)將此行數(shù)
環(huán)評公示相關(guān)推薦
鄂ICP備17016276號-1