Расширение не существует для esbAnalytics: распаковать

Я пытаюсь распаковать входящие события с помощью приложения siddhi на потоковом процессоре WSO2. В более ранней версии (например, DAS) было расширение siddhi esbAnalytics: декомпрессия, но если я использую это расширение в SP, возникает ошибка "Расширения не существует для esbAnalytics: декомпрессия"

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;

Есть ли способ, как использовать esbAnalytics: распаковать на SP или любой другой способ, как распаковать входящее событие flowEntry? Заранее спасибо.

Источник

3 ответа

Решение

esbAnalytic: распаковка - это собственное расширение, написанное на сиддхи 3 . Чтобы использовать его в SP, его нужно перенести в Siddhi 4, так как есть изменения API.

Попробуйте портировать это руководство по написанию пользовательских расширений. Кроме того, Сиддхи 4 идентифицирует расширения, используя аннотации, это закомментировано в сгенерированном коде для простоты использования. Добавьте следующее к расширенному потоковому процессору, как в математическом расширении

@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"
            )
    }
)

После написания расширения поместите банку в каталог {SP_HOME}/lib, чтобы использовать ее в приложении Siddhi.

Источник

На самом деле я перенес это расширение в Siddhi 4 и внес все необходимые изменения, собрал jar-файл и поместил его в каталог lib, но все равно осталась та же ошибка "Расширения для esbAnalytics: не распаковывать". Есть ли какие-либо правила относительно имени этого jar-файла или чего-либо еще, что можно сделать неправильно?

Источник

Вышеупомянутое расширение было выпущено по умолчанию в WSO2 Stream Processor 4.3.0 и выше.

Источник
Другие вопросы по тегам