我有一个应用程序,可以将设备从物理世界映射到 in 。每次从设备接收消息时,我都希望将消息推送到事件中心。
我现在要做的是为每条消息创建/使用/关闭EventHubClient对象。
这是非常低效的(花费大约1500 is ),但它解决了我过去在内存中保存EventHubClient的一个问题。当我有很多设备时,底层虚拟机就会很快耗尽网络连接。
我正在考虑创建一个新的参与者,负责将数据推送到EventHub (通过保持EventHubClient活动)。由于可靠行为者的基于转换的并发模型,我不确定这是一个好主意。如果我得到10000个设备“同时”推送数据,它们的每个参与者都会阻止将消息推送到将
遇到这个设计问题,并尝试找到一种使用JMS实现它的最佳方法。
Web App有一个监听器,多个生产者,多个WorkerBee。侦听器将消息从其队列推送到WorkerBee。生成的所有消息都在侦听器中排队。我想实现一个可以使用某种负载平衡进程将消息从侦听器队列发送到每个WorkerBee的进程。在侦听器队列或WorkerBee队列中只出现一个消息实例。
做这件事最好的方法是什么?在这里,JMS听起来是个不错的选择吗?如何将消息从监听器队列推送到WorkerBee队列?
开放征求意见:)并感谢您的回复。
我希望清除我的企业版Worklight Server v5.0.5上部署在WAS 8.5上的所有推送通知注册。我们有一个用户,只有两个设备,但WL控制台推送通知显示该用户的6个注册设备。似乎有些注册已经重复,或者已经损坏。其中一个设备不再接收推送通知消息,这是以前的工作方式。我尝试删除声明事件源的适配器,甚至重新部署应用程序。但是,当重新部署适配器时,推送通知注册仍然完好无损。您能告诉我如何从WL服务器中清除这些条目吗?
我已经使用本教程部署了简单的PubSub云函数触发器:
为了测试,我将大消息(超过8MB)推送到PubSub主题。
结果,云函数在日志中返回了以下错误消息:Function execution could not start, status: 'request too large'
问题是,Cloud Function开始不断地启动,产生持续的资源使用和日志消息。只有在我手动清除相关的PubSub主题后,它才会停止。
是否有防止此类行为的机制/配置?理想情况下,云函数触发器执行后,PubSub消息不会被再次拾取。
我们有一个用例,其中业务逻辑要求我们连接来自不同数据库的表,并将最终结果推送到输入主题。
table1 from schema1 in database1
table2 from schema2 in database2
业务逻辑
SELECT a,b FROM table1 INNER JOIN table2 ON table1.c = table2.d;
在这里,a来自table1,b来自table2,输入主题中消息的值类似于{ "payload":{ "a":xyz,"b":xyz} }
是否有任何方法可以通过一个jdbc源连接器来实现这一