Procédure DMSRVDATASVC : Envoi de données à un service et sortie vers un jeu de données

/* Préparation des données d'entrée */ libname dqsio "%sysfunc(pathname(WORK))"; DATA dqsio.dfsample; LENGTH ID $10 Nom $20 Prenom $20 Ville $15; INPUT ID $ Nom $ Prenom $ Ville $; DATALINES; 001 Dupont Jean Paris 002 Martin Sylvie Lyon 003 Durand Pierre Marseille 004 Petit Claire Bordeaux 005 LeGrand Michel Toulouse ; RUN; /* Envoi des données d'entrée à un service DataFlux et réception de la sortie */ PROC DMSRVDATASVC HOST='http://localhost' /* Hôte du DataFlux Data Management Server */ PORT=21036 /* Port du service */ SERVICE='analyse_de_donnees.ddf' /* Nom du service DataFlux */ DATA=dqsio.dfsample /* Jeu de données SAS en entrée */ OUT=work.outsrv1_basic /* Jeu de données SAS de sortie */ TIMEOUT=36 /* Délai d'attente du service en secondes */ USERID='utilisateur_test'/* Identifiant de l'utilisateur du service */ PASSWORD='motdepasse_test';/* Mot de passe de l'utilisateur du service */ RUN; /* Affichage des premières lignes du jeu de données de sortie */ PROC PRINT DATA=work.outsrv1_basic(OBS=5); TITLE "Sortie Basique du Service DataFlux"; RUN;

/* Préparation des données d'entrée (identique à l'exemple 1) */ libname dqsio "%sysfunc(pathname(WORK))"; DATA dqsio.dfsample; LENGTH ID $10 Nom $20 Prenom $20 Ville $15; INPUT ID $ Nom $ Prenom $ Ville $; DATALINES; 001 Dupont Jean Paris 002 Martin Sylvie Lyon 003 Durand Pierre Marseille 004 Petit Claire Bordeaux 005 LeGrand Michel Toulouse ; RUN; /* Envoi des données d'entrée avec gestion des logs et un timeout plus long */ PROC DMSRVDATASVC HOST='http://localhost' PORT=21036 SERVICE='validation_adresse.ddf' /* Autre service, par exemple */ DATA=dqsio.dfsample OUT=work.outsrv2_log TIMEOUT=120 /* Délai d'attente étendu */ LOGFILE="/tmp/dmsrv_log.txt" /* Spécifie un fichier de log pour le service */ STATUSFILE="/tmp/dmsrv_status.txt" /* Fichier pour le statut d'exécution */ USERID='utilisateur_test' PASSWORD='motdepasse_test'; RUN; /* Affichage des premières lignes du jeu de données de sortie */ PROC PRINT DATA=work.outsrv2_log(OBS=5); TITLE "Sortie avec Fichiers de Log et Statut"; RUN; /* Affichage du contenu du fichier de log (si créé) */ FILENAME mylog "/tmp/dmsrv_log.txt"; DATA _NULL_; INFILE mylog; INPUT; PUT _INFILE_; RUN; /* Affichage du contenu du fichier de statut (si créé) */ FILENAME mystatus "/tmp/dmsrv_status.txt"; DATA _NULL_; INFILE mystatus; INPUT; PUT _INFILE_; RUN;

/* Préparation des données d'entrée (un sous-ensemble pour l'exemple) */ libname dqsio "%sysfunc(pathname(WORK))"; DATA dqsio.dfsample; LENGTH ID $10 Nom $20 Prenom $20 Ville $15; INPUT ID $ Nom $ Prenom $ Ville $; DATALINES; 001 Dupont Jean Paris 003 Durand Pierre Marseille 005 LeGrand Michel Toulouse ; RUN; /* Définition de macro-variables pour le service et l'authentification */ %LET DMS_HOST = http://localhost; %LET DMS_PORT = 21036; %LET DMS_USER = utilisateur_avance; %LET DMS_PASS = motdepasse_avance; %LET SERVICE_1 = normalisation_noms.ddf; %LET SERVICE_2 = enrichissement_cp.ddf; /* Première exécution : Normalisation des noms */ PROC DMSRVDATASVC HOST="&DMS_HOST" PORT=&DMS_PORT SERVICE="&SERVICE_1" DATA=dqsio.dfsample OUT=work.outsrv3_normalized USERID="&DMS_USER" PASSWORD="&DMS_PASS"; RUN; /* Deuxième exécution : Enrichissement des codes postaux (avec les données normalisées) */ /* Supposons que le service 'enrichissement_cp.ddf' utilise la sortie du premier service */ PROC DMSRVDATASVC HOST="&DMS_HOST" PORT=&DMS_PORT SERVICE="&SERVICE_2" DATA=work.outsrv3_normalized /* Utilise la sortie du premier service comme entrée */ OUT=work.outsrv3_final USERID="&DMS_USER" PASSWORD="&DMS_PASS"; RUN; /* Affichage des premières lignes du jeu de données final */ PROC PRINT DATA=work.outsrv3_final(OBS=5); TITLE "Sortie des Services Multiples DataFlux (Avancé)"; RUN;

/* Établissement d'une session CAS et création d'une bibliothèque CAS */ CAS; libname mycas cas; /* Chargement des données d'entrée vers CAS */ libname dqsio "%sysfunc(pathname(WORK))"; /* Assurez-vous que dqsio pointe vers un emplacement valide */ DATA dqsio.dfsample; LENGTH ID $10 Nom $20 Prenom $20 Ville $15; INPUT ID $ Nom $ Prenom $ Ville $; DATALINES; 001 Dupont Jean Paris 006 Dubois Sophie Nice 007 Bernard Marc Rennes ; RUN; PROC CASUTIL; LOAD DATA=dqsio.dfsample OUTCASLIB=mycas OUTCASF=dfsample_cas; RUN; QUIT; /* Envoi des données CAS à un service DataFlux et réception de la sortie en CAS */ PROC DMSRVDATASVC HOST='http://localhost' PORT=21036 SERVICE='verification_profil.ddf' DATA=mycas.dfsample_cas /* Utilise un jeu de données CAS en entrée */ OUT=mycas.outsrv4_cas /* La sortie est directement chargée en CAS */ TIMEOUT=60 USERID='utilisateur_cas' PASSWORD='motdepasse_cas'; RUN; /* Affichage des premières lignes du jeu de données CAS de sortie */ PROC PRINT DATA=mycas.outsrv4_cas(OBS=5); TITLE "Sortie du Service DataFlux (Intégration CAS)"; RUN; /* Nettoyage : Suppression des tables CAS */ PROC CASUTIL; DROP TABLE=dfsample_cas CASLIB=mycas; DROP TABLE=outsrv4_cas CASLIB=mycas; RUN; QUIT; CAS DISCONNECT;