前回の記事では、Apache Spark を使用して Neo4j に静的なサプライチェーングラフを構築しました。そこでは、サプライヤー、倉庫、流通センター、小売店が輸送ルートで接続されていました。これにより、ある時点でのネットワークのスナップショットが得られました。この記事では、ストリーミングレイヤーを追加します。出荷イベントはリアルタイムで Confluent Cloud Kafka を通過し、エンリッチされたグラフプロパティとして Neo4j に取り込まれ、ライブダッシュボードはイベントの到着に合わせてネットワークの状態を更新して表示します。