Déployez
Pour déployer cette solution, vous devez d'abord configurer le répertoire Project.
Définissez une variable d'environnement pour le répertoire principal du projet.
export PROJECT_DIR=~/morpheus_fraud_detection
mkdir -p $PROJECT_DIR
cd $PROJECT_DIRTerminal 1 : exécution du pipeline Morpheus
Cette commande démarre le couloir d'activité Morpheus Pipeline (Docker Container).
Le pipeline s'initialise, puis attend, en écoutant les données arriver sur
Kafka Topic: Input.cd $PROJECT_DIR/Morpheus
docker run --rm -it --net=host --cap-add=sys_nice \ --runtime=nvidia --gpus=all \ -v $(pwd):/morpheus \ nvcr.io/nvidia/morpheus/morpheus:25.02-runtime bash
# --- INSIDE THE CONTAINER ---
cd /morpheus
conda env update --solver=libmamba -n ${CONDA_DEFAULT_ENV} --file ./conda/environments/examples_cuda-125_arch-$(arch).yaml python examples/gnn_fraud_detection_pipeline/run.pySortie attendue : vous verrez les journaux de Morpheus lors de la création du pipeline. Il semble alors se bloquer, ce qui est le comportement correct car il écoute activement les messages.
Terminal 2 : exécution du destinataire Kafka
Cette commande démarre le destinataire Python dans le couloir d'activité de l'environnement hôte.
Il s'abonne à Kafka Topic: Output et affiche tous les résultats publiés par le pipeline Morpheus.
cd $PROJECT_DIR
source kafka_env/bin/activate
python3 consumer.pySortie attendue : le message
"Listening for fraud detection results..." s'affiche et le terminal attend.
Terminal 3 : exécution du fournisseur de portlets Kafka
Cette commande démarre le fournisseur de portlets Python, qui lit le fichier Transaction Data.
Le signe Input Stream commence par le signe Kafka Topic: Input. Cette action déclenche tout le flux de bout en bout.
cd $PROJECT_DIR
source kafka_env/bin/activate
python3 producer.pySortie attendue : vous verrez une série de messages
"Sent transaction index..." lorsque les données seront publiées. Simultanément, vous verrez le pipeline Morpheus dans le terminal 1 commencer à traiter les données, et les alertes de fraude finales apparaîtront dans le terminal 2.