Eine angepasste Orchestrierungspipelines-Komponente führt ein Script aus, das Sie schreiben. Sie können angepasste Komponenten verwenden, um wiederverwendbare Scripts zwischen Pipelines gemeinsam zu nutzen.
Sie erstellen angepasste Komponenten als Projektassets. Anschließend können Sie die Komponenten in Pipelines verwenden, die Sie in diesem Projekt erstellen. Sie können beliebig viele angepasste Komponenten für Pipelines erstellen. Derzeit müssen Sie mithilfe einer Python -Funktion eine angepasste Komponente programmgesteuert erstellen.
Komponente als Projektasset erstellen
Wenn Sie eine angepasste Komponente erstellen möchten, verwenden Sie den Python -Client für die Authentifizierung bei IBM Orchestration Pipelines, codieren Sie die Komponente und veröffentlichen Sie die Komponente anschließend im angegebenen Projekt. Nachdem sie im Projekt verfügbar ist, können Sie die Komponente einem Knoten in einer Pipeline zuordnen und als Teil eines Pipelineablaufs ausführen.
Dieses Beispiel veranschaulicht den Prozess der Veröffentlichung einer Komponente, die zwei Zahlen addiert und dann die Komponente einem Pipelineknoten zuordnet.
Veröffentlichen Sie eine Funktion als Komponente mit dem Python -Client. Führen Sie den folgenden Code in einem Jupyter Notebook in einem Projekt von Cloud Pak for Data as a Serviceaus.
# 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 )
So generieren Sie einen neuen API-Schlüssel:
- Rufen Sie die IBM Cloud -Startseite auf
- Klicken Sie auf Verwalten > Zugriff (IAM).
- Auf API-Schlüssel klicken
- Klicken Sie auf 'Erstellen'
Ziehen Sie den Knoten Pipelines-Komponente ausführen unter Ausführen in den Erstellungsbereich.
Wählen Sie den Namen der Komponente aus, die verwendet wird.
Verbinden Sie den Knoten als Teil eines Pipeline-Jobs und führen Sie ihn aus.
Pipelinekomponenten verwalten
Verwenden Sie diese Python -Clientmethoden, um angepasste Pipelinekomponenten zu verwalten.
Methode | Funktion |
---|---|
client.get_components(project_id=project_id) |
Komponenten aus einem Projekt auflisten |
client.get_component(project_id=project_id, component_id=component_id) |
Komponente nach ID abrufen |
client.get_component(project_id=project_id, name=component_name) |
Komponente nach Namen abrufen |
client.publish_component(component name) |
Neue Komponente publizieren |
client.delete_component(project_id=project_id, component_id=component_id) |
Komponente nach ID löschen |
Übergeordnetes Thema: Pipeline erstellen