此圖像顯示使用 Oracle Compute Cloud@Customer 、 Kafka ,以及 Docker 容器中的 Morpheus 管線進行即時詐騙預測的管線工作流程,並堆疊在下方。
主機環境:流程會從 Transaction data (validation.csv) 向下開始,直到位於主機環境中的 Python 產生器為止。
Kafka :流程會繼續向下至 Kafka 主題:INPUT (gnn_fraud_input) (位於 Kafka 泳道中)。
Morpheus 管線 (Docker 容器):工作流程會從 INPUT (gnn_fraud_input) 持續到位於 Morpheus 管線泳道的 Kafka 來源。
GNN interface (GraphSAGE)。
GNN interface (GraphSAGE)" (neural network icon) 會連線至 Classification (XGBoost)。
Classification (XGBoost) 以序列化。
Kafka 的接收器會連線至 Kafka 泳道中的 Kafka topic: OUTPUT (gnn_fraud_output)。
Kafka topic: OUTPUT (gnn_fraud_output) 可連線至主機環境 swimlane 中的 Python 用戶。
Python 用戶可連接到主機環境中的即時詐欺預測。