在Pipeline Builder中使用Python函数

前提条件

本指南假设您已经编写并发布了一个Python函数。请查阅我们的Python函数入门文档进行学习。

架构

Python函数在Pipeline Builder管道中作为一个sidecar容器运行。这意味着函数无需部署，并且可以根据管道的规模动态扩展。嵌入的函数可以类似于Pipeline Builder中的其他变换预览。

在Pipeline Builder管道中使用您的函数

按照以下步骤准备并配置您的Python函数：

1. 打开您希望使用Python函数的Pipeline Builder管道。

2. 使用以下两种方法之一将您的UDF导入Pipeline Builder：
   • 从图视图：
     1. 从管道图的上部选择可复用项，然后选择用户定义函数。
        
        
     
     
     2. 选择导入UDF并在可用函数中找到您想使用的函数。
     3. 在函数名称旁边选择添加。该函数应显示一个已导入标签。
        
        
     
     
     4. 关闭导入对话框，并在Pipeline Builder图中选择您希望使用该函数的变换。
     5. 在变换列表中，找到左侧的UDFs标签以查看您导入的函数。
   • 使用变换选择器：
     1. 在管道图中选择变换。
     2. 输入您想导入的UDF名称。
        
        
     
     
     3. 选择搜索未导入的UDF。
     4. 将鼠标悬停在所需的UDF上并选择导入。
        
        
     
     
     
3. 填写变换定义，指定输入列和参数，然后选择应用。

现在，您应该可以在Pipeline Builder图中看到您的Python函数，并可以预览该函数的输出。

在Pipeline Builder中进行外部API调用

要从Pipeline Builder中向外部系统进行API调用，您可以发布一个具有外部系统访问权限的Python函数。这将使您能够编写与外部系统通信的逻辑，并将其作为管道的一部分使用。

要在Pipeline Builder中作为用户定义函数（UDF）使用，函数中使用的所有源必须配置为可导入管道。要配置此设置，请导航到Data Connection中的源，然后转到连接设置 > 代码导入配置选项卡：

一旦您在源上启用了此选项并发布了您的Python函数，它就可以像其他Python函数一样在您的管道中使用。