1

結果をMongoDBバックエンドに保存するCeleryワーカーがいくつかあります。これは非常にうまく機能しているようです。ただし、Neo4J グラフ データベースに一意の taskID を (他のタスク結果のメタ データと共に) 格納する必要もあります。

私の主な目的は、何千もの結果で混乱することなく、Neo4J 内からタスクの結果を参照できるようにすることです。このように、Neo4J はタスク結果の視覚化機能を提供します。

Celery を使用してこれを達成するための最善のアプローチについてアドバイスが必要です。

ここに私がいじってきたオプションのいくつかがあります:

  1. Celery のサブタスクを使用して、個別のワーカーによって処理される個別のタスクを作成して、データを Neo4J に送信します。
  2. Celery の HTTP コールバック タスク (Webhook) を使用して、Neo4J の REST API にデータを直接ポストします。
  3. 主なタスクを拡張して、Neo4J の REST API への呼び出しを含める
4

1 に答える 1