将未知事件流添加到CEP引擎，并获取此事件的所有属性(有效负载)的列表
将未知事件流添加到CEP引擎，并获取此事件的所有属性(有效负载)的列表是指将未知的事件数据流添加到复杂事件处理（CEP）引擎中，并从中获取该事件的所有属性或有效负载的列表。
复杂事件处理（CEP）是一种处理和分析实时数据流的技术，它可以通过定义和检测复杂事件模式来识别和处理特定的事件。在云计算领域，CEP引擎通常用于处理大规模的实时数据流，例如物联网设备生成的传感器数据、网络日志、金融交易数据等。
添加未知事件流到CEP引擎的过程通常包括以下步骤：
- 数据采集：从数据源中采集未知事件流的数据。数据源可以是传感器、日志文件、消息队列等。
- 数据传输：将采集到的数据传输到CEP引擎。这可以通过网络传输、消息中间件等方式实现。
- 事件解析：CEP引擎会对传入的数据进行解析，将其转化为可处理的事件对象。解析过程通常涉及数据格式解析、字段提取等操作。
- 事件处理：CEP引擎会根据预定义的事件处理规则，对事件进行处理和分析。这些规则可以包括简单的条件判断、时间窗口、聚合操作等。
- 属性提取：在处理事件时，CEP引擎可以提取事件的各个属性或有效负载。这些属性可以是事件的时间戳、设备ID、传感器数值等。
通过获取事件的所有属性列表，可以进一步对事件进行分析、存储、可视化等操作。例如，可以将事件属性存储到数据库中，用于后续的查询和分析；或者将事件属性用于实时监控和告警。
在腾讯云的产品生态中，可以使用腾讯云的云原生产品和服务来构建和部署CEP引擎。例如，可以使用腾讯云的容器服务（TKE）来部署CEP引擎的容器化应用，使用腾讯云的消息队列（CMQ）来传输事件数据，使用腾讯云的数据库服务（TDSQL、COS）来存储事件属性等。
腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke 腾讯云消息队列（CMQ）：https://cloud.tencent.com/product/cmq 腾讯云数据库服务（TDSQL、COS）：https://cloud.tencent.com/product/cdb、https://cloud.tencent.com/product/cos
相关·内容
什么是wso2 cep中的元数据相关性数据和有效载荷数据？
我知道这是3种不同类型的数据流数据类型，但是哪种数据类型比另一种数据类型更有好处，这一点在任何文档中都不清楚。或者我们如何在不同的情况下使用它。
所有可以对有效负载数据执行的操作，我也可以对元数据和相关数据执行。
有人能用例子来解释差异吗。
浏览 3提问于2014-09-25得票数 3
回答已采纳
我想建立一个CEP引擎，这是动态的，所以你可以添加不同的事件流。例如，一旦添加了新的流，Esper就应该能够读取流的所有属性并将其放入列表中。(例如整数id、长温度、日期时间戳等)在Esper中这是可能的吗？
将会非常感谢您的帮助
浏览 22提问于2020-11-30得票数 0
下面的链接提供了一个WSO2 CEP示例
https://docs.wso2.com/display/CEP310/Getting+Started+with+CEP
我依次处理这份文件，没有问题。
但是我有个问题想知道如何遵循Siddhi语言
define table pizza_deliveries (deliveredTime long, order_id string);
from deliveryStream
select time, orderNo
insert into pizza_deliveries;
from orderStream#window.time(30 seco
浏览 2提问于2015-02-11得票数 0
回答已采纳
1回答
我正面临着为我们的问题找到最好的CEP产品的困难。我们需要一个具有共享内存的分布式CEP解决方案。分发的主要原因不是加速进程，而是在节点出现硬件或软件问题的情况下进行后备。因此，所有节点都应该保留自己的事件历史副本。
对CEP产品的一些不太重要的要求是：-开源是一个很大的问题。-它应该在Linux系统上运行。+在Java环境中运行会更好。
推荐哪些CEP产品？
浏览 0提问于2013-12-04得票数 0
2回答
我正在使用wso2 cep 4.1，我创建了receiver来捕获来自我的源的一些json数据。然后，我在内部处理此数据，并应给出带有附加数据的响应。我的回应应该是通过与数据进入CEP相同的点。它是经典的rest API。这是可能的吗?我怎样才能做到？或者，我需要websocket (websocket-local)来实现类似的目的？
浏览 0提问于2016-10-03得票数 0
1回答
我希望在流到达WSO2 IoT服务器时立即为它设置到达时间戳，当流被CEP引擎使用时，我希望将它作为摄取时间戳。这些时间将用于计算Queuing latency和CEP latency，如下所示。
Queuing latency = ingestion time - arrival time
CEP latency = detection time - ingestion time
以下是我的执行计划
@Plan:name('Server_CEP')
@Plan:statistics('true')
@Plan:trace('true')
浏览 2提问于2018-05-06得票数 0
回答已采纳
我一直在用siddhi CEP做一些实验，结果让我相信它是一个阻塞CEP，这意味着它不会以高于其处理速度的速度来排队事件。
有人能告诉我更多关于这方面的信息吗？
浏览 4提问于2018-03-29得票数 1
这是对的后续；设置是使用StreamInsight进行时间序列预测。
扩展给出的描述，让我用x_n表示我的输入流，为了这个例子，让我们假设，在每10个观察之后，我预测前面的10个值；我将把这些预测称为p_n。序列指数将与时间相对应，因此第一个p_n将是p_11。
所以我们有
x_1, x_2, ..., x_10 --> p_11, p_12, ..., p_20
x_11, x_12, ..., x_20 --> p_21, p_22, ..., p_30
etc.
我有一个用户定义的流操作符，它从我的输入流中收集x_n，当有足够多的事件时，它会释放出该周期的所有p_n；TXPo
浏览 3提问于2013-06-20得票数 0
1回答
我有两个来自两个Kafka主题的流表，我想加入这些流并对所连接的数据执行聚合功能。需要使用滑动窗口连接流。在连接和窗口数据时，我将得到一个错误Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before.。
下面是代码片段
select cep.payload['id'] , ep.payload['id'] ,
浏览 25提问于2022-05-24得票数 0
1回答
我正在使用wso2cep3.0。我浏览了wso2cep的文档，但没有解释我将如何使用wso2cep。1.Input Event Adapter的用途：-在我从客户那里获取数据的问题上。2.Event Builder表示传入的数据格式说明符。3.Event Formatter表示传出数据格式说明符。4.Output Event Adapter输出输出处理程序。但我如何使用这个东西，意味着任何程序或事件编写器，最重要的是，我如何将其发布到外部世界，例如，作为http端点或https或jms。我无法理解我将如何开始，我可以从哪里开始。请建议我了解ESB、DSS、IS、BPS
浏览 1提问于2014-02-06得票数 0
1回答
下午好。
作为一名架构师，我将软件能力中心写进了Indra公司(www.indra.com)。
在这一领域，通常使用CEP，开源和商业，在开源领域，直到现在我们一直使用Esper CEP，但我们发现GPL存在问题。
在我们好奇地想尝试Siddhi CEP之后，我们已经开始了这个CEP的项目。
问题是我们发现，我们不能确定一个包含所有CEP和项目需求的功能:检测事件的缺失。
在Esper中，这可以通过如下查询来完成：
select a.id, count (*) from pattern [
every a = Status -> (timer: interval (1
浏览 4提问于2013-09-05得票数 3
我想知道从dynamoDB发送数据到elasticsearch的最佳方法是什么。
AWS sdk js.
DynamoDB logstash插件：
浏览 7提问于2017-04-28得票数 2
回答已采纳
我试着理解如何在Flink工程中CEP。例如，来自pages：和。
我想知道Flink CEP应用程序中(Scala)代码的基本结构是什么？
应该使用哪些(必需的)部件、类、函数/方法等，以及按什么顺序使用？
我认为基本部分可以是: 1.模式定义2.模式流定义(或者可以使用许多并行流吗?) 3.选择定义是正确的吗？
如何使用"select part“以及如何查找有关它的更多信息？它看起来相当复杂。
浏览 0提问于2018-03-06得票数 0
我需要能够创建一个事件处理规则，当您添加一个新设备时，您从一个片段(例如: c8y_Hardware.imei)中获取一个字符串值，并使用该字符串填充另一个片段(例如: c8y_Mobile.imei)。因此，新设备在c8y_Hardware.imei和c8y_Mobile.imei中将具有相同的值。
我们已尝试设置适当的CEP规则，但它们不起作用(它们已编译并保存)。
insert into UpdateManagedObject
select
m.id as id,
{
"c8y_Mobile.imei"
浏览 12提问于2019-03-27得票数 0
我目前正在使用cep查询的管理选项卡下的事件处理选项卡获取数据，但只有保存查询后的数据才会被提取.How我们可以基于完整的数据集进行查询吗？
@Name("CarLoadWeekly")
@Resilient
insert into createEvent
select "vechiclecount" as type ,e.event.time as time from EventCreated as e
where (e.text ='active')
浏览 0提问于2018-03-27得票数 2
2回答
WSO2复杂事件处理器
、、、
我对WSO2 CEP有一点小问题。我使用的是版本3.1.0，并且我有一个JMS队列。因此，在我的队列中，我有一些不同类型的事件，而在CEP中，我有相同数量的不同执行计划。我的问题是，我如何区分传入的事件，因为现在只有一个执行计划可以正常工作，并且它可以获得所有类型的事件(所以我得到了很多错误，因为只有一个事件可以与此计划一起工作，而其他事件不能)。这是可能的吗，我正在做的事情？也许有人以前遇到过这个问题，可以回答我。
Kacu
浏览 3提问于2014-06-10得票数 0
我是WSO2 Cep的新手，我想问是否有人知道我如何从WSO2 CEP管理控制台导出事件流、事件接收器等以便进行备份？
提前感谢！
浏览 5提问于2017-03-24得票数 0
回答已采纳
我正在测试flink cep，我的水印被定义为行时间，我的表是一个kafka表。由于水印依赖于所有kafka分区的最小值，所以每一条新消息都必须等待kafka分区对齐，然后cep触发结果。
我的kafka表(主题有3个分区)被定义为
create table test_table(
agent_id String, room_id String,
create_time Bigint,
call_type String,
application_id String,
connect_time Bigint,
row_time as to
浏览 4提问于2021-10-30得票数 0
回答已采纳
8回答
我想学习更多关于如何建立基于CEP的应用程序。所以我环顾四周，发现了几个产品(在这里可以找到概述：)。
但由于目前有相当多，我不知道哪一个是最好的开始。总体而言，我只考虑免费的那个。其余的对于私人使用来说有点太贵了;)
Esper是免费的，但如果没有Esper studio，开发一个cep应用程序似乎相当乏味。Streambase提供免费试用，但我不知道你可以使用多久(如果只使用一个月，对更长时间的研究没有什么帮助)。Oracle CEP套件似乎相当完整，但在cep场景中-据我所知-与Esper或Streambase相比，它是最不被认可的。
那么，你有什么建议是开始cep开发的最好方法吗？是否
浏览 10提问于2009-05-26得票数 12
回答已采纳
我想知道WSO2 CEP是如何工作的，Event Stream很简单，但是Event Store是什么呢？它可以存储设备历史，但在哪里？我想到的是Spark，它只在内存中存储数据，对吗？如果我想将设备历史记录存储在RDMS中，我能做什么？谢谢
浏览 1提问于2016-06-07得票数 0
回答已采纳
1回答
我对esper引擎是个新手，对多数据流的含义也不是很确定。我想要创建这样的东西：
CepEnigine cep = new CepEngine();
Controller.getInstance().setRuntime(cep.getRuntime());
for(int i = 0; i < 5; i++)
new EventGenerator().start();
事件生成器类的定义如下：
public class EventGenerator extends Thread
{
@Override
public void run()
{
浏览 3提问于2013-10-03得票数 0
3回答
我最近一直在研究基于事件的系统，并了解到使用Apache Storm等框架进行复杂的事件处理。我知道，当您处理大量数据流，并且希望检测数据中的某些事件时，CEP是理想的选择，我们向CEP引擎提供查询来检测事件。
如果每分钟产生的数据流不是很大，但是您有一组更大的查询提供给CEP，那该怎么办呢？在这种情况下，CEP仍然是理想的吗？如果不是，最好的方法是什么？
浏览 6提问于2014-09-04得票数 0
2回答
我使用事件格式化程序和事件生成器在我的WSO2 CEP (v3.1.0)中创建输入和输出流。我需要找出这些流是在WSO2 CEP目录结构中创建的，因为除了事件生成器和格式化程序(wso2cep-3.1.0\存储库\部署\server)之外，我找不到它。
有人知道我在哪里能找到这些流文件吗？
卡库
浏览 3提问于2014-06-17得票数 0
回答已采纳
下面是我的输入XML数据：
<property>
<name>stringName</name>
<value>stringValue</value>
</property>
实际数据：
<events>
<event>
<payloadData>
<property>
<name>event_GUID</name>
<value>0ca0dfbe-087f-11e5-b174
浏览 5提问于2017-04-04得票数 0
1回答
我正在开发一个工具，用于收集Git存储库上的度量。我试图弄清楚如何计算一个push中的提交数，这样我就可以说“对于存储库x，平均的y提交是在推送之前完成的”。在这种情况下，可以忽略合并提交。我尝试使用libgit2，但没有成功，因为我不相信Git本身将这些信息存储在其对象数据库中。
虽然GitHub似乎可以推断出什么时候有了推送，所以它必须是可能的。GitHub在主页中显示了提交者最近提交的一个列表(对于您是成员的组织和跟踪的人员)，并在它们一起推送时将提交显示为压缩在一起。
如何使用GitHub API或其他库获取这些信息？
浏览 0提问于2015-01-16得票数 2
回答已采纳
我是wso2产品的新手。我正在为设备和应用程序使用EMM。但我想持续监控我的设备。
正如一些文档所建议的，我可以使用CEP实时完成这项工作，也可以使用BAM。但是我没有找到任何合适的文档来安装或配置这些系统(EMM、CEP、BAM)。
我的EMM服务器已经处于活动状态。我现在正在尝试分析http访问日志，以找出注册失败或其他错误。
但我实际上需要实时监控EMM服务器。
我是否需要单独运行这些服务器，也需要单独配置它们？有没有办法合并所有(EMM，CEP，BAM，甚至ESS)应用程序，并通过运行一个carbon服务器来运行所有这些应用程序？
如果我需要单独运行这些服务器，那么我如何配置CEP/B
浏览 8提问于2015-12-03得票数 0
1回答
我已经成功地在Solaris10机器上安装了wso2 cep引擎。作为事件，我正在接收UDP提要(管道分隔的数据线)。如何配置CEP引擎以接收UDP源并对其进行处理？
谢谢
浏览 0提问于2012-11-06得票数 0
回答已采纳
1回答
我需要处理一个输入流，并将处理后的流与输入流具有相同的模式发布到记录器。
换句话说，对于导入和导出定义，我需要使用相同的模式。我该如何解决这个问题？
使用siddhi QL在wso2 cep中可以做到这一点吗？
浏览 0提问于2015-11-28得票数 0
我一直在寻找如何使用apache storm作为CEP，但似乎有两个概念(流处理和复杂事件处理)，在CEP中，你可以编写类似sql的查询，它们在数据流上执行，就像ESPER，但我在apache storm中找不到任何类似的东西，这是不是意味着apache storm是一个数据流处理器而不是CEP？
浏览 16提问于2017-02-12得票数 0
我的目标是与发布者和使用者一起创建一个分布式应用程序，在其中我使用CEP处理数据流，以生成事件使用者的事件通知。
Esper和Apache Storm有什么区别？
我能否实现Storm只使用Esper的功能，以及何时应该考虑将Esper与Storm集成？
我很困惑，我以为Esper提供了同样的功能。
浏览 8提问于2017-03-07得票数 3
回答已采纳
问题1：我正在研究一个案例场景，我们需要融合来自多个传感器的数据，例如8个传感器，并以树的形式将它们连接起来。例如，加入s1、s2、s3 s4来形成流A，然后加入s5、s6、s7和s8来形成B流，然后在流A和B上执行CEP。
问题2 :可以在多个流上执行CEP吗？中清楚地提到，模式将应用于一个流。
DataStream<Event> input = ...
Pattern<Event, ?> pattern = ...
PatternStream<Event> patternStream = CEP.pattern(input, pattern);
如果不
浏览 4提问于2017-10-29得票数 2
回答已采纳
我在GitHub Action workflow_call遇到了一种奇怪的行为。
基本上，在初始设置之后，一切都可以正常工作，但是当我编辑工作流文件的输入参数时，它不使用更新的值。很难用语言来解释，所以让我给你举个例子。
考虑一下这个基本设置：
文件：start-pipeline.yml
name: Start Pipeline
on:
workflow_dispatch:
inputs:
release_type:
required: true
type: choice
options:
- patc
浏览 30提问于2022-03-13得票数 6
回答已采纳
1回答
创建小工具失败
、、
我已经在cep控制台中定义了一个数据源，移动到cep analytics仪表板，并尝试创建一个新的小工具。此操作将失败，并显示错误。没有可用的数据源。查看用于创建小工具的源代码，会发现对分析服务存根的依赖不是默认安装的一部分。我切换到使用DAS，得到了同样的错误。有没有人有什么建议可以让它工作？
浏览 1提问于2016-02-27得票数 0
我的问题是，如果我们有两个原始事件流，即烟雾流和温度流，并且我们想知道是否有复杂的事件，即Fire，通过将操作符应用于原始流，我们能在Flink中这样做吗？
我之所以问这个问题，是因为到目前为止，我所看到的Flink CEP的所有例子都只有一个输入流。如果我错了，请纠正我。
浏览 0提问于2017-07-28得票数 2
回答已采纳
1回答
在研究如何在github操作中使用文件的拉请求("head")版本区分存储库中特定文件的“基本”版本时.在研究这个问题时，我在各种源(例如，和中的代码示例)中找到了.我发现以下上下文变量是可用的：
github.ref
github.sha
github.event.pull_request.head.ref
github.event.pull_request.head.sha
github.event.pull_request.base.ref
github.event.pull_request.base.sha
但是，除了前两个(github
浏览 6提问于2021-11-25得票数 9
回答已采纳
1回答
我从上下文代理(两者都在localhost中)向Proton CEP发送了一个REST post请求，但是当它接收到该事件时，它无法读取xml。这是catalina日志：
may 20, 2015 9:38:52 AM com.ibm.hrl.proton.webapp.providers.EventXmlNgsiMessageReader readFrom
INFORMACIÓN: started event message body reader
may 20, 2015 9:38:52 AM com.ibm.hrl.proton.webapp.providers.EventXmlNgsi
浏览 3提问于2015-05-19得票数 1
1回答
在WSO2 CEP中是否有解释事件生命周期的文档/文章？我不太明白事件是如何从事件流中被丢弃的。
谢谢你，雨果·卡拉多
浏览 2提问于2016-02-08得票数 0
回答已采纳
1回答
我需要在一个项目中使用WSO2 CEP3.0，但我对此一无所知。我的想法是使用CEP引擎作为触发器，在我创建的一个小型Cassandra数据库上，在另一个字段被更改时编辑一个字段。
我已经阅读了官方文档，在支持论坛上搜索过(包括堆栈溢出)，在谷歌上搜索过，但我仍然不知道我必须遵循哪些步骤。
如果有人能为完成这项任务提供一些解释或任何文件，我将不胜感激。
提前谢谢。
浏览 1提问于2014-01-14得票数 0
回答已采纳
#message.payloadAs(java.lang.String)在骡子esb中的用途是什么？？
有人能用一个例子来解释我吗。当从When服务获得对我的骡子esb的响应时。当我将简单记录器与#有效负载放在一起时，我可以在日志中看到一些简单的哈希码，比如@1b8353(但不能看到有效负载消息xml)。但是，当使用#message.payloadAs(java.lang.String)进行日志记录时，我能够清楚地看到有效负载xml正在被记录。有人能解释清楚它的目的吗？
请作出进一步澄清！
浏览 1提问于2015-07-22得票数 2
在WSO2Cep上，我定义了一个事件格式化程序。在定义执行计划时，我希望在导出流部分选择此事件格式化程序。但是在标有“事件格式化程序”的组合框中，可用的选项是默认事件格式化程序和自定义事件格式化程序。如何链接到先前定义的事件格式化程序？
浏览 3提问于2013-12-12得票数 0
回答已采纳
有没有办法使用在不同主机上发布的事件？更准确地说:如果我有两个CEP服务器运行在不同的主机上，我如何将查询绑定到运行在不同CEP引擎中的事件生产者。我也非常感谢一些真实的例子。
浏览 0提问于2010-07-09得票数 0
回答已采纳
1回答
我们想要实现一个“新闻提要”，用户可以看到由她的朋友广播的信息，首先与最新消息排序。但是这个提要应该反映她的好友列表中的变化。(如果她添加了新朋友，则这些消息应该包含在提要中，如果她删除了好友，则不应该包含这些消息。)如果我们使用示例并在每条消息上附加一个收件人列表，这意味着当用户连接和断开朋友时，会对邮件收件人列表进行大量操作。
我们首先使用传统的RDBMS思想对发布-订阅“扇出”进行建模。它一开始看起来很管用，但是后来，由于IN操作符的工作方式，我们很快意识到我们不能继续这样做。我们找到了，现在已经看过几次了，但是我们还不清楚如何使用“动态”收件人列表来实现它。
我们需要的是在建模时如何“
浏览 2提问于2010-03-15得票数 6
回答已采纳
1回答
进出商店的流量事件？
、、、、
我试图把我的头围绕着Flux，实际上我有一个人为的例子在工作，但是我对事件流有点困惑。假设我定义了一个名为TestAction的操作。我的观点有一个onClick，它发出了这样的事件；
Dispatcher.dispatch(new TestAction(this.state.currentValue));
太好了，它流到商店去了。到目前为止，很好，我明白了。
现在，我的商店做任何魔术，与服务器交谈等，并更新自己。然后，由于某种原因，所有的例子都显示了商店沿着这些路线做了一些事情；
Dispatcher.register((action: Action) => {
if (actio
浏览 3提问于2015-09-18得票数 0
回答已采纳
1回答
复杂事件处理和环形缓冲区中断有什么区别？两者都用于接收低延迟和较少使用系统资源的数据。当然，带有esper的CEP将根据我们的epl查询触发事件。除此之外，还有什么区别吗？什么时候我们应该选择CEP，什么时候应该使用环形缓冲器？
浏览 1提问于2018-04-08得票数 0
回答已采纳
模式匹配算法是规则引擎或复杂事件流处理引擎中的主要算法。在我学习的过程中，drools规则引擎使用rete算法进行模式匹配。像siddhi，FlinkCEP和Esper这样的复杂事件流处理引擎是做什么的。我在网上浏览了一下，没有得到任何关于这方面的信息。请让我理解在CEP和规则引擎中使用的模式匹配。还有，规则引擎和CEP之间的区别是什么，因为它们对我来说看起来都很相似。
浏览 9提问于2018-01-25得票数 1
1回答
我想检测所有相同整数的序列，后面跟着这些整数的计数。有什么方法可以用Flink CEP库创建这个模式吗？假设如下：
val input List(1,2,2,2,3,3,2,1,1,1,3,0,1)
这些序列应该被检测到：
List(2,2,2,3)
List(3,3,2)
List(1,1,1)
我知道有很多方法可以通过Flink本身来完成它，但是我想用CEP来完成它，我认为它需要支持将上下文传递到下一个条件，对吗？如果是这样的话，Flink CEP是否可以传递上下文或修改流中的事件，并将一些额外的数据传递给下一个条件？
浏览 6提问于2022-09-10得票数 0
回答已采纳
1回答
我有个问题。
在一次采访中，有人问我，如果scatter-gather的其中一个路由失败，我们会得到输出吗？我的回答是“否”，因为scatter-gather总是给出从所有路由获取的统一有效负载，然后他们问我是否还想从成功的路由中获取有效负载，我应该怎么做，以及我用Try scope -> on-error continue回答的问题。(我希望我在这里，如果我没有的话，请解释一下)。
他们给我的下一个场景是这样的:如果我有一个分散聚集的错误传播集，并且我也有一个有效负载。因此，当路由失败并且处理程序进入on-error-propagate时，是否打印存在的有效负载。我对这个问题的回答是肯
浏览 24提问于2021-10-07得票数 0
我正在使用wso2cep3.1.0。我通过订阅ActiveMQ来接受输入。但是我想将wso2cep的内容输出到REST api。我该怎么做呢？？
浏览 1提问于2014-11-24得票数 0
1回答
我想听听你对IoT数据摄入案例的见解。在AWS IoT集线器中，物体阴影是物理阴影的虚拟表示。我从下图中了解到的是，每当一个事物通过消息代理向平台发送数据时，事物阴影和规则引擎部分就会并发地获取相同的传感器数据并对其进行处理。
我的结论正确吗？
Things影子系统订阅message并获取传感器数据，更新它们的影子参与者。阴影侧还负责存储传感器数据，这是一种事件来源机制。
事物影子系统不执行任何规则，它只用于执行事件源和在虚拟事物参与者中保持最后已知的状态。
相同的传感器数据也是规则引擎的入站数据。规则引擎是公正的，事件条件动作( ECA )类型的系统处理流数据，并决定它将如何处理
浏览 2提问于2017-07-19得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
