結果をMongoDBバックエンドに保存するCeleryワーカーがいくつかあります。これは非常にうまく機能しているようです。ただし、Neo4J グラフ データベースに一意の taskID を (他のタスク結果のメタ データと共に) 格納する必要もあります。
私の主な目的は、何千もの結果で混乱することなく、Neo4J 内からタスクの結果を参照できるようにすることです。このように、Neo4J はタスク結果の視覚化機能を提供します。
Celery を使用してこれを達成するための最善のアプローチについてアドバイスが必要です。
ここに私がいじってきたオプションのいくつかがあります：
- Celery のサブタスクを使用して、個別のワーカーによって処理される個別のタスクを作成して、データを Neo4J に送信します。
- Celery の HTTP コールバック タスク (Webhook) を使用して、Neo4J の REST API にデータを直接ポストします。
- 主なタスクを拡張して、Neo4J の REST API への呼び出しを含める