Exécuter Job en boucle

[fbmhm]

Slt tt le monde;
J'ai un job de transfert des données entre deux bases PostgreSQL,(Clients ==> Serveur).
Mon Job prend en entréé l'adresse IP de la machine Client.
Les @IP des clients sont stockées dans une table iptables sur le Serveur.
Je suis arrivé a créer mon job qui permet de récupérer les IP des clients et effectuer le transfert(en itération: client après l'autre) a partir des clients .
Mon problème c si la machine client ne répond pas (erreur de connexion réseau), normalement le job doit passer a @IP suivante mais se bloque et mettre fin du job.
Je voudrais faire quelque chose comme: On Error Resume Next.

[CyberChouan]

Il faudrait que tu trouves un moyen d'intercepter et d'ignorer l'exception.

Voici une idée :

Tu mets la liste de tes adresse IP dans un flux dans un composant d'entrée.

Tu places en suite un tJavaFlex configuré comme cela :

Begin

Code :

try {

Main

Code :

context.ip = IN.ip;

End

Code :

1
2
3
} catch (Exception e) {
    // Adresse injoignable : passage à la suivante
}

Enfin, le tRunJob qui effectueras le traitement pour l'adresse IP en question, (obtenue à partir du contexte transmis).

Pour résumer :

Liste des IP --> tJavaFlex --> tRunJob

La composition des éléments Talend fera en sorte que le code global du traitement sera le suivant (en pseudo-code), correspondant à ton besoin :

Code :

1
2
3
4
5
6
7
8
FOR (adresseIP) {
    try {
        context.ip = adresseIP;
        executeSousJob(context);
    } catch (Exception e) {
        // Erreur pour adresseIP : passage à la suivante
    }
}

[fbmhm]

[quote=fbmhm;6113277]Slt tt le monde;
J'ai un job de transfert des données entre deux bases PostgreSQL,(Clients ==> Serveur).
Mon Job prend en entréé l'adresse IP de la machine Client.
Les @IP des clients sont stockées dans une table iptables sur le Serveur.
Je suis arrivé a créer mon job qui permet de récupérer les IP des clients et effectuer le transfert(en itération: client après l'autre) a partir des clients .
Mon problème c si la machine client ne répond pas (erreur de connexion réseau), normalement le job doit passer a @IP suivante mais se bloque et mettre fin du job.
Je voudrais faire quelque chose comme: On Error Resume Next.

[emenuet]

Bonjour,

Tu peux créer un job qui fait ton mapping, avec un context pour paramétrer l'IP

Dans ton job master ( celui en piece jointe ) tu fait une iteration sur le tRunjob en passant l'IP comme paramètre ( le tableau paramètre de contexte ) et tu décoches "arret en cas d'erreur du fils"

Ainsi, si ton sous-job plante pour une adresse IP, le traitement continu pour l'IP suivante.

[NicoL__]

Peut-être qu'avec des tServerAlive cela évitera d'avoir à gérer une erreur ?