MarkLogicのCPFとタスクサーバー8

Question

文書の挿入と更新時にCPFを作成しました。これらのCPFパイプラインは、さまざまなタスクを実行するために複数のxdmp:spawn-tasksを作成します。私はこのアプローチにいくつかの質問があります。

1. 生成されたタスクの中には、元のドキュメントを変更するものがあります。これにより、CPFの更新ワークフローがトリガーされますか？ドキュメント上で、それが生成されたタスクからの更新であることを示すフラグを使用できます。しかし、これを行うよりエレガントな方法はありますか？
2. デッドロックについて心配する必要はありますか？つまり、同じCPFから作成された2つのタスクが同じドキュメントを同じ時刻に更新しようとしたら、どうすればこの問題を回避できますか？

基本的には、挿入したドキュメントに封筒パターンを使用して、すべてのアーティファクトドキュメントを1つのドキュメントにまとめようとしています。私がこのアーティファクト文書を生成するためにCPFを使用しているのは、カスタムのRESTエンドポイントを使用する代わりに、MLCPやその他の方法でデータベースに文書をダンプして、CPFに処理を心配させて、カスタムRESTエンドポイント。

Answer 1

私はタスクを生成して、手元のドキュメントに更新を適用することをお勧めします。このような更新は、CPF状態の自然な流れを妨げることになる。 CPF自体は、複数の州を経由して文書を取得するように設計されており、それぞれの移行が合計の変換に貢献します。

したがって、ドキュメントを複数のCPF状態にして、そのような状態遷移（パイプライン）のうちの1つ以上で更新を行います。各状態遷移はすでに別のトランザクションであるため、タスクを生成する必要はありません。

デッドロックについて心配する必要はありませんが、更新プログラムの並列実行によって、更新プログラムの一部が互いに上書きされる可能性があるため、失われると簡単に想像することができます。その種類は、使用している正確なコードに依存します。 MarkLogicのトランザクションメカニズムは、通常、これを守りますが、そのメカニズムをバイパスするコードを書くのは簡単です。

HTH！