小编Dom*_*kal的帖子

将统计信息从wso2 EI发布到wso2流处理器

我需要知道如何通过事件发布者从Enteprise Integrator到流处理器发布统计信息。

我在EI上执行了事件发布者的以下实现

<?xml version="1.0" encoding="UTF-8"?>
<eventPublisher name="MessageFlowStatisticsPublisher"
  statistics="enable" trace="enable" xmlns="http://wso2.org/carbon/eventpublisher">
  <from streamName="org.wso2.esb.analytics.stream.FlowEntry" version="1.0.0"/>
  <mapping customMapping="disable" type="wso2event"/>
  <to eventAdapterType="wso2event">
    <property name="username">admin</property>
    <property name="protocol">thrift</property>
    <property name="publishingMode">non-blocking</property>
    <property name="publishTimeout">0</property>
    <property name="receiverURL">tcp://xxx:7611</property>
    <property encrypted="true" name="password">xxx</property>
  </to>
</eventPublisher>
Run Code Online (Sandbox Code Playgroud)

在流处理器上,我有一个简单的siddhi应用程序,用于接收数据并将其打印到日志中,如下所示

@App:name("FlowEntryApp")
@App:description("Plan of flow entry")

@source(type='wso2event', @map(type = 'wso2event'))
define stream FlowEntry(compressed bool, tenantId int, messageId string, flowData string);

@sink(type='log', prefix='My flowEntry:')
define stream TestOutputFlowEntry(messageId string, flowData string);

@info(name='FlowEntryOutput')
from FlowEntry
select messageId, flowData
group by messageId
insert into TestOutputFlowEntry;
Run Code Online (Sandbox Code Playgroud)

另外,我将发布统计信息的所有配置都设置为代理服务的“启用统计信息”和“启用跟踪”。当我调用服务时,eventPublisher将wso2event发送到SP,这可以正常工作。但是在SP端,SP处理错误“缓存中存在streamId org.wso2.esb.analytics.stream.FlowEntry:1.0.0的没有StreamDefinition”

我知道,这个问题出在siddhi应用程序中,我定义了流“ FlowEntry”而不是“ …

wso2 complex-event-processing siddhi ei wso2sp

5
推荐指数
1
解决办法
475
查看次数

如何在Nest JS中迭代@Query()对象

有什么办法,如何通过@Query()注释迭代在控制器中获得的对象?

我们在GET中具有动态计数和查询参数的名称,因此我们需要获取整个@Query()对象并对其进行迭代,以了解我们确切拥有的paramas。

但是,如果我要遍历该对象,则会收到错误消息,指出该对象不可迭代。

任何想法如何做到这一点?

javascript node.js typescript nestjs

3
推荐指数
1
解决办法
920
查看次数

Keycloak - 与来自不同领域的用户一起管理领域

是否可以让一个领域的用户在 keycloak 中管理另一个领域?我的目标是拥有 2 个领域 - adminRealm 和 userRalm。在 adminRealm 中应该是用户,他们将能够登录到我们的管理应用程序,并且他们可以在那里通过 Keycloak rest api 创建“普通用户”,该“普通用户”将被放置到 userRealm 中。

目前我的解决方案在一个领域内工作,我有管理员用户,可以登录我的管理应用程序,并且他可以在同一领域创建用户。但是如果我想将用户创建到另一个领域,我会收到 403 错误。那么有什么方法可以让管理员用户管理另一个领域(例如创建用户等)?

realm keycloak keycloak-rest-api

2
推荐指数
1
解决办法
2450
查看次数