Déployez
Pour déployer cette solution, vous devez d'abord configurer le répertoire Project.
Définissez une variable d'environnement pour votre répertoire de projet principal.
export PROJECT_DIR=~/morpheus_fraud_detection
mkdir -p $PROJECT_DIR
cd $PROJECT_DIRTerminal 1 : Exécuter le pipeline Morpheus
Cette commande démarre le couloir d'activité Morpheus Pipeline (Docker Container).
Le pipeline s'initialisera, puis attendra l'arrivée des données 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 semblera alors s'accrocher, ce qui est le comportement correct car il est maintenant activement à l'écoute des messages.
Terminal 2 : Exécuter le consommateur Kafka
Cette commande démarre le consommateur Python dans le couloir d'activité de l'environnement hôte.
Il s'abonne au 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 : Vous verrez le message
"Listening for fraud detection results..." et le terminal attendra.
Terminal 3 : Exécuter le fournisseur Kafka
Cette commande démarre le fournisseur de portlets Python, qui lit le fichier Transaction Data.
Il commence Input Stream dans Kafka Topic: Input. Cette action déclenche l'ensemble du 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 démarrer le traitement des données, et les alertes de fraude finales apparaîtront dans le Terminal 2.