esbAnalytics:decompress 没有扩展名

Question

我正在尝试使用 WSO2 流处理器上的 siddhi 应用程序解压缩传入事件。在早期版本（例如 DAS）上有 siddhi 扩展 esbAnalytics:decompress，但如果我在 SP 中使用此扩展，则会出现错误 "No extension exist for esbAnalytics:decompress"

from FlowEntry#esbAnalytics:decompress(meta_compressed, meta_tenantId, flowData, messageId)
select messageFlowId, host, hashCode, componentName, componentType, componentIndex, componentId,  startTime, endTime, duration, beforePayload, afterPayload, contextPropertyMap, transportPropertyMap, children, entryPoint, entryPointHashcode, faultCount,metaTenantId, _timestamp
group by messageFlowId
insert into TestOutputFlowEntry;

有什么方法可以在 SP 上使用 esbAnalytics:decompress 或任何其他方法可以解压缩传入的 flowEntry 事件？提前致谢。

Answer 1

esbAnalytic: decompress 是一个用 Siddhi 3 编写的 custom extension。为了在 SP 中使用它，需要将其移植到 Siddhi 4，因为有 API 更改。

试试自定义扩展写作 guide, to port this. Also, Siddhi 4, identifies the extensions using annotations, this is commented out on the generated code for ease of use. Add the following to the extended Stream Processor as in math extension

@Extension(
    name = "decompress",
    namespace = "esbAnalytics",
    description = "decompress function",
    examples = {
            @Example(
                    syntax = "FlowEntry" +
                            "#esbAnalytics:decompress(meta_compressed, meta_tenantId, flowData, messageId)\n",
                    description = "the above syntax can be used"
            )
    }
)

编写扩展后，将 jar 放在 {SP_HOME}/lib 目录中，以便在 Siddhi 应用程序中使用它。

Answer 2

实际上我将此扩展移植到 Siddhi 4 并进行了所有必要的更改，构建 jar 文件并将其放入 lib 目录，但仍然存在相同的错误 "No extension exist for esbAnalytics:decompress"。是否有关于该 jar 文件的名称或其他任何可能出错的规则？

Answer 3

以上扩展已在 WSO2 Stream Processor 4.3.0 后默认发布。

esbAnalytics:decompress 没有扩展名

No extension exist for esbAnalytics:decompress

wso2

siddhi

event-stream-processing

wso2sp