ラクダでバッチ処理する方法

Question

いくつかの入力CSVファイルを処理し、SpringデータNeo4jを使用してNeo4jにロードするETLをいくつか実行しています。 私は2つのルートを1つずつ入力CSVを分割し、トランスナショナル・モードで1行ずつロードする2番目のルートに送信します。

次は、最初のルート

---

@Override 
void configure() throws Exception { 
    from(endpoint) 
      .id('CSV_ROUTE') 
      .unmarshal(buildCsvDataFormat()) 
      .split(body()) 
      .streaming() 
      .parallelProcessing() 
      .recipientList(header('IMPORTER_ROUTE')) 

---

そして次は私がMAKするにはどうすればよい第2の経路

---

@Override 
void configure() throws Exception { 
    from(endpoint) 
      .transacted() 
      .id(routeId) 
      .bean(importer) 
} 

---

ですeトランザクションは、すべての行ではなく10行のバッチでコミットするか？

は、あなたがこれを行うことはできません ルイスオスカー

Answer 1

ありがとうございます。トランザクションはCamelのメッセージごとです。

また、念入りなトランザクションは、あなたがオンにすることができるいくつかの魔法の妖精ダストではなく、あなたが触れるものはトランザクションになります。

Javaトランザクションでは、多くの場合、JDBCやJMSなどのトランザクション・リソースでしか動作しません。