我需要知道如何通过事件发布者从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”而不是“ …
有什么办法,如何通过@Query()
注释迭代在控制器中获得的对象?
我们在GET中具有动态计数和查询参数的名称,因此我们需要获取整个@Query()
对象并对其进行迭代,以了解我们确切拥有的paramas。
但是,如果我要遍历该对象,则会收到错误消息,指出该对象不可迭代。
任何想法如何做到这一点?
是否可以让一个领域的用户在 keycloak 中管理另一个领域?我的目标是拥有 2 个领域 - adminRealm 和 userRalm。在 adminRealm 中应该是用户,他们将能够登录到我们的管理应用程序,并且他们可以在那里通过 Keycloak rest api 创建“普通用户”,该“普通用户”将被放置到 userRealm 中。
目前我的解决方案在一个领域内工作,我有管理员用户,可以登录我的管理应用程序,并且他可以在同一领域创建用户。但是如果我想将用户创建到另一个领域,我会收到 403 错误。那么有什么方法可以让管理员用户管理另一个领域(例如创建用户等)?
ei ×1
javascript ×1
keycloak ×1
nestjs ×1
node.js ×1
realm ×1
siddhi ×1
typescript ×1
wso2 ×1
wso2sp ×1