我正在嘗試使用 Camel 中的 Rest DSL 處理一個(gè) csv 文件。當(dāng)我將 CSV 和 Marshall 拆分為 JSON 時(shí)，我遇到了一些奇怪的行為。這是我的代碼：@Componentpublic classProcessHandler extends RouteBuilder { @Override protected void defineRoute() throws Exception { DataFormat csv = new BindyCsvDataFormat(CsvModel.class); rest("/") .post().produces("application/json") .route() .unmarshal(csv) .split(body()).parallelProcessing().streaming() .marshal().json(JsonLibrary.Gson) .filter().jsonpath("$[?(@.counter==3)]") .log("${body}")但是我收到錯(cuò)誤消息：Error during type conversion from type: java.lang.String to the required type: byte[] with value [CsvModel(....但是，如果我按如下方式編輯路線：@Componentpublic classProcessHandler extends RouteBuilder { @Override protected void defineRoute() throws Exception { DataFormat csv = new BindyCsvDataFormat(CsvModel.class); rest("/") .post().produces("application/json") .route() .unmarshal(csv) .marshal().json(JsonLibrary.Gson) .split(body()).parallelProcessing().streaming() //.filter().jsonpath("$[?(@.counter==3)]") .log("${body}")它工作正常。然而，我顯然無法正確處理我的消息，因?yàn)樗痪幗M為字節(jié)表示。如果不使用 Rest DSL，該路由也能正常工作，所以我假設(shè)問題出在 http 響應(yīng)上。如果我嘗試以下操作：我犯了同樣的錯(cuò)誤。能不能規(guī)范化格式，做一些處理步驟，然后返回一個(gè)Json？我在某個(gè)地方出錯(cuò)了嗎 - 我很樂意理解為什么會(huì)這樣？
1 回答
慕少森
TA貢獻(xiàn)2019條經(jīng)驗(yàn) 獲得超9個(gè)贊
如果您在內(nèi)部過濾而不是使用 JsonPath 來實(shí)施聚合策略，可能會(huì)更容易，因此更容易理解。
實(shí)際上，split()默認(rèn)情況下使用的方法不會(huì)給出您期望的結(jié)果
這是一個(gè)例子：
@Component
public class ProcessHandler extends RouteBuilder {
? ? ? ? ? ? @Override
? ? ? ? ? ? protected void defineRoute() throws Exception {
? ? ? ? ? ? DataFormat csv = new BindyCsvDataFormat(CsvModel.class);
? ? ? ? ? ? rest("/")
? ? ? ? ? ? ? ? ? ? .post().produces("application/json")
? ? ? ? ? ? ? ? ? ? ? ? ?.route()
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .unmarshal(csv)
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .split().method(ItemsSplittingStrategy.class, "splitItems")
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .parallelProcessing()
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .marshal().json(JsonLibrary.Gson)
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .end()
? ? ? ? ? ? ? ? ? ? .to("file:/file.json");
? ? }
}
我還邀請您檢查可用于拆分器和聚合器及其組合的所有功能。
添加回答
舉報(bào)
0/150
提交
取消