0 / 0
Zurück zur englischen Version der Dokumentation
Angepasste Komponente für die Verwendung in der Pipeline erstellen
Letzte Aktualisierung: 10. Juni 2024
Angepasste Komponente für die Verwendung in der Pipeline erstellen

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.

  1. 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:

    1. Rufen Sie die IBM Cloud -Startseite auf
    2. Klicken Sie auf Verwalten > Zugriff (IAM).
    3. Auf API-Schlüssel klicken
    4. Klicken Sie auf 'Erstellen'
  2. Ziehen Sie den Knoten Pipelines-Komponente ausführen unter Ausführen in den Erstellungsbereich.
    Angepassten Komponentenknoten abrufen

  3. Wählen Sie den Namen der Komponente aus, die verwendet wird.
    Tatsächliche Komponentenfunktion auswählen

  4. Verbinden Sie den Knoten als Teil eines Pipeline-Jobs und führen Sie ihn aus.
    Komponente verbinden

Pipelinekomponenten verwalten

Verwenden Sie diese Python -Clientmethoden, um angepasste Pipelinekomponenten zu verwalten.

Tabelle 1. Pipelinekomponenten 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

Generative KI-Suche und -Antwort
Diese Antworten werden von einem großen Sprachmodell in watsonx.ai basierend auf dem Inhalt der Produktdokumentation generiert. Weitere Informationen