创建组件作为项目资产

要创建定制组件，请使用 Python 客户机向 IBM Orchestration Pipeline 进行认证，对组件进行编码，然后将组件发布到指定的项目。 在项目中提供组件后，可以将组件分配给管道中的节点，并将其作为管道流的一部分运行。

此示例演示了发布组件的过程，该组件将两个数字相加，然后将该组件分配给管道节点。

1. 使用 Python 客户机将函数作为组件发布。 在 Cloud Pak for Data as a Service项目中的 Jupyter Notebook 中运行以下代码。

   # 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 
   )
   

   要生成新的 API 密钥:

   1. 转至 IBM Cloud 主页
   2. 单击 "管理> 访问权 (IAM)"
   3. 单击 API 密钥
   4. 单击创建

2. 将名为 运行管道组件 的节点拖到画布上的 运行 下。
   

3. 选择要使用的组件的名称。
   

4. 作为管道作业的一部分连接并运行节点。
   
   

管理管道组件

使用这些 Python 客户机方法来管理定制管道组件。

父主题: 创建管道