Un composant personnalisé de pipelines d'orchestration exécute un script que vous écrivez. Vous pouvez utiliser des composants personnalisés pour partager des scripts réutilisables entre des pipelines.
Vous créez des composants personnalisés en tant qu'actifs de projet. Vous pouvez ensuite utiliser les composants dans les pipelines que vous créez dans ce projet. Vous pouvez créer autant de composants personnalisés que nécessaire pour les pipelines. Actuellement, vous devez créer un composant personnalisé à l'aide d'un programme, à l'aide d'une fonction Python .
Création d'un composant en tant qu'actif de projet
Pour créer un composant personnalisé, utilisez le client Python pour vous authentifier avec IBM Orchestration Pipelines, codez le composant, puis publiez le composant dans le projet spécifié. Une fois qu'il est disponible dans le projet, vous pouvez affecter le composant à un noeud dans un pipeline et l'exécuter dans le cadre d'un flux de pipeline.
Cet exemple illustre le processus de publication d'un composant qui ajoute deux numéros ensemble, puis affecte le composant à un noeud de pipeline.
Publiez une fonction en tant que composant avec le client Python . Exécutez le code suivant dans un Jupyter Notebook dans un projet IBM watsonx.
# Install libraries ! pip install ibm-orchestration-pipelines # Authentication from ibm_orchestration_pipelines import OrchestrationPipelines apikey = '' project_id = 'your_project_id' client = OrchestrationPipelines(apikey, url=service_url) # Define the function of the component # If you define the input parameters, users are required to # input them in the UI def add_two_numbers(a: int, b: int) -> int: print('Adding numbers: {} + {}.'.format(a, b)) return a + b + 10 # Other possible functions might be sending a Slack message, # or listing directories in a storage volume, and so on. # Publish the component client.publish_component( name='Add numbers', # Appears in UI as component name func=add_two_numbers, description='Custom component adding numbers', # Appears in UI as component description project_id=project_id, overwrite=True, # Overwrites an existing component with the same name )
Pour générer une nouvelle clé d'API:
- Accédez à la page d'accueil d'IBM Cloud
- Cliquez sur Gérer > Accès (IAM)
- Cliquez sur les clés d'API
- Cliquez sur Créer
Faites glisser le noeud appelé Exécuter le composant Pipelines sous Exécuter dans l'espace de travail.
Choisissez le nom du composant à utiliser.
Connectez et exécutez le noeud dans le cadre d'un travail de pipeline.
Gérer les composants de pipeline
Utilisez ces méthodes client Python pour gérer les composants de pipeline personnalisés.
Méthode | Fonction |
---|---|
client.get_components(project_id=project_id) |
Répertorier les composants d'un projet |
client.get_component(project_id=project_id, component_id=component_id) |
Obtenir un composant par ID |
client.get_component(project_id=project_id, name=component_name) |
Obtenir un composant par nom |
client.publish_component(component name) |
Publier un nouveau composant |
client.delete_component(project_id=project_id, component_id=component_id) |
Supprimer un composant par ID |
Rubrique parent: Création d'un pipeline