Microsoft Fabric - 尝试一下在pipeline中发送请求给web api(获取数据和更新数据)

1.简单介绍

Microsoft Fabric中的Pipeline支持很多种activity，分成数据转换和控制流两种类型的activitly。

这边将尝试一下发送web请求的activity，要做成的pipeline大概如下图所示，

上图中有4个Activity，作用如下

Web - 从一个Web Api中获取数据

Office 365 Outlook - 将获取到的数据发送给特定用户

ForEach - 遍历从Web Api获取的数据，然后调用另外一个Web Api接口逐条更新数据

Teams - 数据更新完成，发送信息到Teams Channel中

感觉有点像Power Automate或者Logic Apps

2.具体说明

这个pipeline要实现的功能是从web api中获取所有的TodoItem，然后更新Todoitem的状态为已完成，并发送信息到outlook和Microsoft Teams中。 

下面是大概的过程说明

2.1 制作Web Api

假定有一个TodoItem的WebApi，支持对TodoItem进行增删改查的操作

        

        

TodoItem WebApi 是.NET9 Minimal Api，使用别的语言也可以的。这个Web Api是需要公网可以访问的，因此Microsoft Farbic是要访问到这个Web Api的。如果本地开发的项目，也可以使用一些工具(比如花生壳)来映射到公网中，从而Microsoft Fabric能正常访问的。

2.2 制作Data Pipeline

1) 在workspace中，创建一个Data Pipeline

        

2）点击Pipeline界面右侧的...，然后搜索并选择Web Activity

        

        

3) 配置Web Activity，创建与Web Api的connection,如下图

        

        

4) 添加Office 365 Outlook activity并连接Web activity与Outlook activity

         

note, Web activity的On success接口与Office 365 Outlook进行连接。表示Web activity执行成功了才开始执行Office 365 Outlook activity。 

         

note, Office 365 Outlook acitivity的 Body可以使用Pipeline中的expression和function进行定制的  

5）添加ForEach activity并连接Web activity与ForEach activity

        

6) 创建好连接后，配置ForEach的Items，这个也可以使用Pipeline特有的expression进行。公式的具体使用与Power Automate有点像。 

        

        7)  

7) ForEach activity的内部可以添加子activity

通过上面的步骤, ForEach activity获取到了Web Api的数据了(Items)，接着就可以遍历数据进行后续的操作了。 

        

点击上图中edit图标，可以进去到ForEach activity的内部，在内部还可以添加Web activity如下图，

        

8) 配置子Web activity，如下图

        

Http Method选择PUT, 根据接口的不同，还可以选择别的Http Method. Web Request的Body内容也可以进行定制的

        

9）退出ForEach activity，然后连接ForEach activity与 Teams activity

        

10) 设定Teams activity

可以配置信息往哪个Team的哪个Channel进行发送，信息的内容也可以定制的。 

        

2.3 验证和运行

2.3.1 验证一下

先点击Pipeline界面中的Validate按钮验证一下有没有错误，

        

验证好后，会在Pipeline界面的右侧显示如下panel，表示验证通过了

        

2.3.2 运行一下

 点击Pipeline界面上面的Run按钮开始运行，

        

等待一些时间后，发现特定的outlook已经有邮件出现了 

同时Pipeline的运行结果也显示成功

Teams中的特定的Channel也有信息出现，

        

 最后再次查询一下Web Api中的TodoItem的状态，确实已经变更为Completed

        

初始的TodoItem数据IsComplete如下

        

3.总结

本文简单记录了一下在Microsoft Fabric Data Pipeline中使用Web activity进行TodoItem的数据获取和更新的过程。制作过程中，具体的细节相对多一些, Data Pipeline中还可以使用Dataflow, Notebook等，功能很强大的。Microsoft Fabric平台的知识体量很大，后续还需继续跟着微软的老师们学习一下。

本文如果哪里有错误，麻烦告之，谢谢谢谢！