Un componente personalizzato di Orchestration Pipelines esegue uno script che viene scritto. È possibile utilizzare i componenti personalizzati per condividere script riutilizzabili tra le pipeline.
I componenti personalizzati vengono creati come asset di progetto. È quindi possibile utilizzare i componenti nelle pipeline create in tale progetto. È possibile creare tutti i componenti personalizzati per le pipeline necessari. Attualmente, devi creare un componente personalizzato in modo programmatico, utilizzando una funzione Python .
Creazione di un componente come asset di un progetto
Per creare un componente personalizzato, utilizzare il client Python per autenticarsi con IBM Orchestration Pipelines, codificare il componente, quindi pubblicare il componente nel progetto specificato. Una volta disponibile nel progetto, è possibile assegnare il componente a un nodo in una pipeline ed eseguirlo come parte di un flusso della pipeline.
Questo esempio illustra il processo di pubblicazione di un componente che aggiunge due numeri insieme, quindi assegna il componente ad un nodo pipeline.
Pubblica una funzione come componente con il client Python . Immetti il seguente codice in Jupyter Notebook in un progetto di 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 )
Per creare una nuova chiave API:
- Vai alla home page diIBM Cloud .
- Fai clic su Gestisci> Accesso (IAM)
- Fare clic su Chiavi API
- Fai clic su Crea
Trascinare il nodo denominato Esegui componente Pipeline in Esegui nell'area.
Scegliere il nome del componente che si desidera utilizzare.
Connettersi ed eseguire il nodo come parte di un lavoro pipeline.
Gestisci componenti pipeline
Utilizza questi metodi client Python per gestire i componenti pipeline personalizzati.
Metodo | Funzione |
---|---|
client.get_components(project_id=project_id) |
Elencare i componenti da un progetto |
client.get_component(project_id=project_id, component_id=component_id) |
Acquisisci un componente per ID |
client.get_component(project_id=project_id, name=component_name) |
Ottieni un componente per nome |
client.publish_component(component name) |
Pubblica un nuovo componente |
client.delete_component(project_id=project_id, component_id=component_id) |
Elimina un componente per ID |
Argomento principale: Creazione di una pipeline