Azure 逻辑应用中的内置连接器
通过内置连接器,你可以控制工作流的计划和结构、运行自己的代码、管理或操作数据,以及完成工作流中的其他任务。 不同于托管连接器,一些内置连接器没有与特定服务、系统或协议相关联。 例如,你可以使用“定期”触发器启动计划上的几乎任何工作流。 或者可以使用“请求”触发器,使工作流在被调用以前都保持等待状态。 所有内置连接器都在 Azure 逻辑应用运行时上以原生方式运行。 一些内置连接器不要求在对其进行使用前创建连接。
对于少数服务、系统和协议,Azure 逻辑应用同时提供了内置版本和托管版本。 内置连接器的数量和范围因你创建的是在多租户 Azure 逻辑应用中运行的消耗型逻辑应用工作流,还是在单租户 Azure 逻辑应用中运行的标准型逻辑应用工作流而异。 在大多数情况下,内置版本提供更好的性能、更全面的功能以及更实惠的价格。 在少数情况下,某些内置连接器仅在一种逻辑应用工作流中可用,而在另一种逻辑应用工作流中不可用。
例如,标准工作流可以为 Azure Blob 存储、Azure Cosmos DB、Azure 事件中心、Azure 服务总线、FTP、IBM DB2、IBM MQ、SFTP 和 SQL Server 使用托管连接器和内置连接器。 消耗型工作流没有内置版本。 消耗型工作流可以为 Azure API 管理和 Azure 应用服务使用内置连接器,而标准工作流则没有这些内置连接器。
在标准工作流中,某些具有特定属性的内置连接器称为“服务提供程序”(非正式)。 一些内置连接器仅支持一种方法来验证与基础服务的连接。 其他内置连接器可以提供选择,例如使用连接字符串、Microsoft Entra ID 或托管标识。 所有内置连接器都与 Azure 逻辑应用运行时在同一进程中运行。 有关详细信息,请查看 Azure 逻辑应用中的单租户与多租户。
本文提供有关消耗型工作流与标准工作流中的内置连接器的一般概述。
消耗型逻辑应用与标准型逻辑应用中的内置连接器
下表列出了可用于消耗型和标准工作流的内置连接器的当前库和扩展库。 对于标准工作流,星号 (*) 会根据服务提供程序模型标记内置连接器,这部分内容稍后将进行更详细的介绍。
消耗 | Standard |
---|---|
Azure API 管理 Azure 应用服务 Azure Functions Azure 逻辑应用 批处理 控制 数据操作 DateTime 平面文件 HTTP 内联代码 集成帐户 Liquid 请求 计划 变量 XML |
AS2 (v2) Azure AI 搜索* Azure 自动化* Azure Blob 存储* Azure Cosmos DB* Azure 事件网格发布服务器* Azure 事件中心* Azure 文件存储* Azure Functions Azure Key Vault* Azure OpenAI* Azure 队列存储* Azure 服务总线* Azure 表存储* 批处理操作 控制 数据映射器操作 数据操作 DateTime EDIFACT 文件系统* 平面文件 FTP* HTTP IBM DB2* IBM 主机文件* IBM MQ* 内联代码 集成帐户 JDBC* Liquid 操作 请求 RosettaNet SAP* 计划 SFTP* SMTP* SQL Server* SWIFT 变量 工作流操作 X12 XML 操作 |
基于服务提供程序的内置连接器
在标准工作流中,具有以下属性的内置连接器被非正式地称为服务提供程序:
提供从标准工作流到服务的访问,例如 Azure Blob 存储、Azure 服务总线、Azure 事件中心、SFTP 和 SQL Server。
一些内置连接器仅支持一种方法来验证与基础服务的连接。 其他内置连接器可以提供选择,例如使用连接字符串、Microsoft Entra ID 或托管标识。
与重新设计的 Azure 逻辑应用运行时在同一进程中运行。
基于服务提供商的内置连接器与其托管连接器版本一起提供。
相比之下,不是服务提供程序的内置连接器具有以下特性:
不基于 Azure Functions 扩展性模型。
直接实现为 Azure 逻辑应用运行时中的作业,例如计划、HTTP、请求和 XML 操作。
自定义内置连接器
对于标准工作流,可以使用基于服务提供程序的内置连接器(例如 Azure Blob 存储、Azure 事件中心、Azure 服务总线、SQL Server 等)使用的同一内置连接器扩展性模型创建自己的内置连接器。 此接口实现基于 Azure Functions 扩展性模型,并提供了功能来供你创建任何人都可以在标准工作流中使用的自定义内置连接器。
对于消耗型工作流,你无法创建自己的内置连接器,但可以创建自己的托管连接器。
有关详细信息,请查看以下文档:
常规内置连接器
可以使用以下内置连接器来执行常规任务,例如:
使用自定义计划和高级计划运行工作流。 有关计划的详细信息,请查看 Azure 逻辑应用中连接器的定期行为。
组织和控制工作流的结构(例如使用循环和条件执行此操作)。
利用变量、日期、数据操作、内容转换和批处理操作。
使用 HTTP 触发器和操作与其他终结点通信。
接收和响应请求。
调用自己的函数 (Azure Functions) 或其他可以接收请求的 Azure 逻辑应用工作流等。
计划
重复:根据指定的重复周期触发工作流。
滑动窗口
(仅限消耗型工作流)
触发需要处理连续区块中的数据的工作流。
延迟:在指定的持续时间内暂停工作流。
延迟截止时间:在指定的日期和时间之前暂停工作流。
HTTP
使用 HTTP 触发器或操作调用 HTTP 或 HTTPS 终结点。
还可使用以下其他内置 HTTP 触发器和操作:
Request
收到 HTTP 请求时:等待来自其他工作流、应用或服务的请求。 此触发器使工作流可调用,而无需根据计划进行检查或轮询。
响应:响应由同一工作流中的“收到 HTTP 请求时”触发器接收的请求。
批处理
批处理消息:触发批量处理消息的工作流。
发送要批量处理的消息:调用当前以“批处理消息”触发器开头的现有工作流。
文件系统
(仅限标准型工作流)
连接到网络计算机上的文件系统以创建和管理文件。
FTP
(仅限标准型工作流)
连接到你的 Azure 虚拟网络中的 FTP 或 FTPS 服务器,以便处理你的文件和文件夹。
SFTP
(仅限标准型工作流)
连接到你的 Azure 虚拟网络中的 SFTP 服务器,以便处理你的文件和文件夹。
SMTP
(仅限标准型工作流)
连接到 SMTP 服务器,以便发送电子邮件。
特定服务和系统的内置连接器
可以使用以下内置连接器访问特定服务和系统。 在标准工作流中,其中一些内置连接器也被非正式地称为服务提供程序,它们在某些方面可能与对应的托管连接器不同。
Azure AI 搜索
(仅限标准型工作流)
连接到 AI 搜索,以便在工作流中执行文档索引和搜索操作。
Azure API 管理
(仅限消耗型工作流)
使用 Azure API 管理在你定义、管理和发布的 API 中调用自己的触发器和操作。
注意:使用 API 管理的消耗层时不受支持。
Azure 应用程序服务
(仅限消耗型工作流)
调用在 Azure 应用服务上创建和托管的应用,如 API 应用和 Web 应用。
包含 Swagger 后,由这些应用定义的触发器和操作将与 Azure 逻辑应用中的其他任何第一类触发器和操作类似。
Azure 自动化
(仅限标准型工作流)
连接到 Azure 自动化帐户,以便创建和管理 Azure 自动化作业。
Azure Blob 存储
(仅限标准型工作流)
连接到 Azure Blob 存储帐户,以便可以创建和管理 Blob 内容。
Azure Cosmos DB
(仅限标准型工作流)
连接到 Azure Cosmos DB,以便可以访问和管理 Azure Cosmos DB 文档。
Azure 事件网格发布服务器
(仅限标准型工作流)
连接到 Azure 事件网格,以使用 pub-sub 语义进行基于事件的编程。
Azure 事件中心
(仅限标准型工作流)
通过事件中心使用和发布事件。 例如,通过事件中心获取工作流的输出,然后将输出发送到实时分析提供程序。
Azure 文件存储
(仅限标准型工作流)
连接到 Azure 存储帐户,以便可以创建、更新和管理文件。
Azure Functions
调用 Azure 托管的函数,在工作流中运行自己的代码片段(C# 或 Node.js)。
Azure Key Vault
(仅限标准型工作流)
连接到 Azure Key Vault 以存储、访问和管理机密。
Azure 逻辑应用
(消耗型工作流)
- 或者 -
工作流操作
(标准型工作流)
调用其他以名为“收到 HTTP 请求时”的“请求”触发器开头的工作流。
Azure OpenAI
(仅限标准型工作流)
连接到 Azure OpenAI,以对大语言模型执行操作。
Azure 服务总线
(仅限标准型工作流)
管理异步消息、队列、会话、主题和主题订阅。
Azure 表存储
(仅限标准型工作流)
连接到 Azure 存储帐户,以便创建、更新、查询和管理表。
IBM DB2
(仅限标准型工作流)
连接到云中或本地的 IBM DB2。 更新行、获取表,等等。
IBM MQ
(仅限标准型工作流)
连接到本地或 Azure 中的 IBM MQ 以发送和接收消息。
JDBC
(仅限标准型工作流)
使用 JDBC 驱动程序连接到关系数据库。
SAP
(仅限标准型工作流)
连接到 SAP,以便发送或接收消息并调用操作。
SQL Server
(仅限标准型工作流)
连接到本地 SQL Server 或云中的 Azure SQL 数据库,以便可以管理记录、运行存储过程或执行查询。
从工作流运行代码
Azure 逻辑应用提供用于在工作流中运行自己的代码的以下内置操作:
Azure Functions
调用 Azure 托管的函数,在工作流中运行自己的代码片段(C# 或 Node.js)。
本地函数操作
(仅限标准型工作流)
从工作流创建和运行 .NET Framework 代码。
控制工作流
Azure 逻辑应用提供用于在工作流中构建和控制操作的以下内置操作:
条件
评估条件,并根据条件是 true 还是 false 运行不同的操作。
对每个
对数组中的每个项执行相同的操作。
[作用域][scope-doc]
将操作分组到范围,以便在该范围内的操作完成运行后,获取这些操作的自身状态。
Switch
将操作分组到案例,而案例分配有唯一的值(默认案例除外)。 仅运行其分配值与表达式、对象或令牌的结果相匹配的案例。 如果不存在任何匹配项,则运行默认案例。
终止
停止正在运行的工作流。
Until
重复操作,直到指定的条件为 true 或某个状态发生更改。
管理或处理数据
Azure 逻辑应用提供了以下用于处理数据输出及其格式的内置操作:
数据操作
对数据执行操作。
撰写:基于具有不同类型的多个输入创建单个输出。
创建 CSV 表:基于包含 JSON 对象的数组创建逗号分隔值 (CSV) 表。
创建 HTML 表:基于包含 JSON 对象的数组创建一个 HTML 表。
筛选数组:基于符合条件的另一个数组中的项创建一个数组。
联接:基于数组中的所有项创建一个字符串,并使用指定的分隔符分隔这些项。
分析 JSON:基于 JSON 内容中的属性及其值创建用户友好的令牌,以便可以在工作流中使用这些属性。
选择:通过转换另一数组中的项或值并将这些项映射到指定的属性,创建包含 JSON 对象的数组。
日期时间
对时间戳执行操作。
添加到时间:将指定的单位数添加到时间戳。
转换时区:将时间戳从源时区转换为目标时区。
当前时间:返回字符串形式的当前时间戳。
获取将来的时间:返回当前时间戳加上指定的时间单位。
获取过去的时间:返回当前时间戳减去指定的时间单位。
从时间中减去:从时间戳中减去一定数目的时间单位。
变量
对变量执行操作。
追加到数组变量:插入一个值,作为变量存储的数组中的最后一个项。
追加到字符串变量:插入一个值,作为变量存储的字符串中的最后一个字符。
递减变量:按常量值减小变量。
递增变量:按常量值增大变量。
初始化变量:创建一个变量并声明其数据类型和初始值。
设置变量:将不同的值分配给现有变量。
企业对企业 (B2B) 内置操作
Azure 逻辑应用通过各种企业对企业 (B2B) 内置操作支持 B2B 通信方案。 根据使用的是消耗型工作流还是标准工作流以及你想要使用的 B2B 操作,你可能需要创建集成帐户并将其链接到逻辑应用资源。 然后,使用此集成帐户来定义 B2B 项目,例如贸易合作伙伴、协议、映射、架构、证书等等。
消耗型工作流
必须创建集成帐户并将其链接到逻辑应用资源,然后才能在工作流中使用任何 B2B 操作。 创建集成帐户后,必须定义 B2B 项目,例如贸易合作伙伴、协议、映射、架构、证书等等。 然后,可以使用 B2B 操作对消息进行编码和解码、转换内容等。
标准型工作流
某些 B2B 操作要求你创建集成帐户并将其链接到逻辑应用资源。 通过链接,你可以跨多个标准工作流及其子工作流共享项目。 根据你想要使用的 B2B 操作,在执行该操作之前完成以下步骤之一:
对于需要映射或架构的操作,可执行以下操作之一:
使用 Azure 门户或 Visual Studio Code 将这些项目上传到逻辑应用资源。 然后,可以在同一逻辑应用资源中跨所有子工作流使用这些项目。 有关详细信息,请查看添加映射以用于 Azure 逻辑应用中的工作流和添加架构以用于 Azure 逻辑应用中的工作流。
对于需要连接到集成帐户的操作,请在将操作添加到工作流时创建连接。
有关详细信息,请查看以下文档:
AS2 (v2)
(仅限标准型工作流)
对使用 AS2 协议的消息进行编码和解码。
EDIFACT
对使用 EDIFACT 协议的消息进行编码和解码。
平面文件
对贸易伙伴之间的 XML 消息进行编码和解码。
集成帐户项目查找
获取集成帐户中项目的自定义元数据,例如参与方、协议、架构等。
Liquid 操作
使用 Liquid 模板转换以下格式:
- JSON 到 JSON
- JSON 到 TEXT
- XML 到 JSON
- XML 到 TEXT
RosettaNet
对使用 RosettaNet 协议的消息进行编码和解码。
SWIFT
(仅限标准型工作流)
对平面文件 XML 消息格式的环球银行金融电讯协会 (SIWFT) 事务进行编码和解码。
转换 XML
将源 XML 格式转换为另一种 XML 格式。
X12
对使用 X12 协议的消息进行编码和解码。
XML 验证
根据指定的架构验证 XML 文档。