WSO2 SP中如何解析wso2event的XML格式Payload至变量？

我来帮你搞定WSO2 Stream Processor里解析wso2event中XML payload的问题，其实核心是把wso2event的输入配置和Siddhi的XML解析函数结合起来，一步步来：

1. 先定义输入流和解析后的目标流 #

首先得明确两个流：一个是接收原始wso2event的输入流，另一个是存储解析后结构化数据的目标流。示例如下：

-- 原始输入流：接收wso2event，包含timestamp和XML格式的payload字符串
define stream RawWSO2EventStream (timestamp long, payload string);

-- 解析后的目标流：把XML里的字段提取出来，这里假设XML包含orderId、customerName、amount三个字段
define stream ParsedEventStream (timestamp long, orderId string, customerName string, amount double);

2. 配置WSO2 Event Source #

接下来配置接收wso2event的source，这里要注意指定正确的接收地址（和你的SP部署配置对应）：

@source(
    type='wso2event',
    receiver.url='tcp://localhost:9612', -- 替换成你的wso2event接收地址
    @map(type='wso2event')
)
define stream RawWSO2EventStream (timestamp long, payload string);

这里的@map(type='wso2event')是告诉Siddhi用wso2event的格式来解析输入的事件，这样就能正确拿到timestamp和payload字段。

3. 编写查询解析XML Payload #

这一步是核心：用Siddhi的XML扩展函数，从payload字段里提取你需要的变量。示例查询如下：

@info(name='parse-xml-payload')
from RawWSO2EventStream
select
    timestamp,
    -- 用XPath提取XML节点文本，这里假设XML根节点是<order>
    xml:getElementText(payload, "/order/id") as orderId,
    xml:getElementText(payload, "/order/customer/name") as customerName,
    -- 把提取到的字符串转成数字类型
    xml:toDouble(xml:getElementText(payload, "/order/amount")) as amount
insert into ParsedEventStream;

关键说明： #

• xml:getElementText()：根据你传入的XPath表达式，从payload的XML字符串里提取对应节点的文本内容。
• 类型转换：如果XML里的字段是数字/布尔值，用xml:toDouble()、xml:toInt()这类函数转成对应类型。
• 调整XPath：如果你的XML结构不同，只需要修改XPath路径就行。比如你的XML是<transaction><id>T123</id></transaction>，那XPath就改成"/transaction/id"。

4. 验证配置 #

确保你已经启用了siddhi-map-xml扩展（WSO2 SP默认已经包含这个扩展，如果没启用的话，去SP的extensions目录确认下有没有这个jar包）。启动SP后，发送包含XML payload的wso2event，就能在ParsedEventStream里看到解析后的结构化数据了。

内容的提问来源于stack exchange，提问作者Dominik Zatloukal