/ / Créer une transformation et des étapes Pentaho avec Java - java, pentaho, etl, kettle, pentaho-cde

Créer un Pentaho Transformation & Steps en Java - java, pentaho, etl, kettle, pentaho-cde

Je suis très nouveau à Pentaho / ETL et besoin d'un expertconseille de terminer mon travail. En fait, nous essayons d’intégrer Pentaho Steps / Jobs à notre plate-forme Web. Nous concevons une interface similaire dans laquelle l’utilisateur obtiendra la liste des étapes et pourra choisir une étape pour créer une transformation. Nous développons actuellement des interfaces HTML similaires pour toutes les boîtes de dialogue des étapes pentaho. Nous enverrons les données de transformation (y compris les étapes / sauts) au format JSON aux API dorsales. Les API dorsales analyseront le JSON et créeront les étapes / transMeta pour Kettle moteur de base. Quelqu'un peut-il m'aider s'il vous plaît sur la façon de créer des étapes / transformation en Java?, Vous pouvez également suggérer une bonne stratégie de conception pour implémenter ce scénario. Votre aide est tres apprecie.

Réponses:

1 pour la réponse № 1

Ouvrez n’importe quel fichier ktr, kjb dans un éditeur de textetrouver que c'est juste un document XML. Étudiez comment chaque étape est représentée dans un document XML, comment elle contient les variables, les champs, l’état actuel, comment les étapes sont liées les unes aux autres.

Quand vous pourrez construire un document XML qui correspond à ce que vous voyez dans le navigateur.

Générez une transformation ou une tâche au format XML et transmettez-la au moteur à l'aide de l'API dans la documentation de la bouilloire.

Je pense que ça va prendre du temps. Je ne pense pas que cela vaille la peine de traduire toutes les étapes, mais au moins, vous pouvez mettre en œuvre un petit sous-ensemble d’étapes nécessaires.


0 pour la réponse № 2

J'ai utilisé un modèle d'usine pour écrire mon analyseur JSON qui analyse la demande json et crée des étapes et sauts pentaho et les ajoute à une transformation. (Utilisation des API Java PDI).

J'exécute la transformation en tant que tâche asynchrone et je conserve un cache pour enregistrer la sortie du journal de transformation.

Je serais heureux d'aider si quelqu'un cherche des explications détaillées.