我正在开发一个接受 100k+ 唯一输入的应用程序——为简单起见，我们假设每个输入都是一个浮点值(a、b、c 等)——尽管它们也可以是字符串等。该应用程序有许多与这些输入相关的规则/事件/触发器。
示例 1:
Rule[(a > b) and (c <= d)] --> [execute EventX]
定义1:上面的规则说:当输入'a'的值大于'b'并且输入'c'的值小于或等于'时d' 执行 EventX
例子2:
Rule[x != x.prev] --> [execute EventZ]
定义2:上面的规则说:如果在值更新后，如果输入'x'的当前值不等于它以前的值(值已经改变)。执行EventZ
我发现随着输入数量的增加和规则数量的增加，评估“特定”规则并确定是否应触发事件所需的总计算量正在减少control - 在问题上 throw 更快和更多 h/w 并没有按预期扩展。
目前，在每次新的输入更新时，都会在哈希表中查找关联的输入/变量，该哈希表将变量映射到包含它的规则。随后对这些规则中的每一个进行评估，如果结果为真或可操作，则异步触发相关事件。
这个问题属于复杂事件处理领域，不幸的是，这个领域中的大多数架构都使用与上述相同的无用方法——可能有一些与评估/重新评估的频率相关的改进。我们的想法是拥有一个可以近乎实时地使用react的系统。在多个节点上分布规则和输入似乎也不太奏效，因为在某些情况下，少数输入存在于超过 95% 的事件规则中。
我希望那里是否有任何 SO'ers，他们知道解决这个问题、数据/结构或算法的更好方法。
我想到的一个简单想法是，可以构造一个依赖逻辑推理列表。
如果有两条规则是这样的:
Rule[a < b] --> [exec E1]
Rule[b >= a] --> [exec E2]
然后对“a”或“b”的更新不应该需要对两者进行评估等。但我发现构建这样的逻辑推理结构非常复杂且容易出错，并且难以完全和严格地测试。
输入可以代表股票价格、温度传感器等。
另外请注意，一些输入在时间上受到限制，这意味着规则可能要求变量的状态在一段时间内处于特定位置/状态(例如:最后一次 MSFT 的价格 > 20 美元30 秒)，目前这是通过使用值为 0 或 1/false 或 true 的“表示变量”(外观)来实现的(变量的值由单独的机制确定，通常是规则被触发)。
还应注意，由于接近实时的限制和每秒生成的数据量，使用带有触发器和存储过程的数据库的选项是不可能的。
最佳答案
一些想法。
如果您的规则的条件是连词，则为每个不满足的条件维护一个不满足的条件。仅将规则放在该术语的检查列表中。如果该术语得到满足，则扫描其他术语以确定条件是否已触发或是否存在另一个不满足的术语。 (我想我是在 SAT 求解器的上下文中了解到这个技巧的。)
如果您有 10 <= x=""><= 50="" 这样的术语，请使用="">interval tree而不是散列来快速定位将要通过对 x 的更新变得不满意的满意条款和即将变得满意的不满意条款。 (完全搜索 O(log n)，加上每个返回结果的 O(1)。)如果一次只考虑一个变量会产生太多虚假命中，则存在多维概括，但它们的维护成本会更高。
如果您没有这样的术语(例如，a <= b)，请进行派生输入="" (b="" -="" a)="">
关于c++ - 处理大量规则(条件和约束)CEP 系统，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10167856/
Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时，rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack
我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server
我有一个用户工厂。我希望默认情况下确认用户。但是鉴于unconfirmed特征，我不希望它们被确认。虽然我有一个基于实现细节而不是抽象的工作实现，但我想知道如何正确地做到这一点。factory:userdoafter(:create)do|user,evaluator|#unwantedimplementationdetailshereunlessFactoryGirl.factories[:user].defined_traits.map(&:name).include?(:unconfirmed)user.confirm!endendtrait:unconfirmeddoenden
我有一些代码在几个不同的位置之一运行:作为具有调试输出的命令行工具，作为不接受任何输出的更大程序的一部分，以及在Rails环境中。有时我需要根据代码的位置对代码进行细微的更改，我意识到以下样式似乎可行:print"Testingnestedfunctionsdefined\n"CLI=trueifCLIdeftest_printprint"CommandLineVersion\n"endelsedeftest_printprint"ReleaseVersion\n"endendtest_print()这导致:TestingnestedfunctionsdefinedCommandLin
我有一个只接受一个参数的方法:defmy_method(number)end如果使用number调用方法，我该如何引发错误？？通常，我如何定义方法参数的条件？比如我想在调用的时候报错:my_method(1) 最佳答案 您可以添加guard在函数的开头，如果参数无效则引发异常。例如:defmy_method(number)failArgumentError,"Inputshouldbegreaterthanorequalto2"ifnumbereputse.messageend#=>Inputshouldbegreaterthano
电脑0x0000001A蓝屏错误怎么U盘重装系统教学分享。有用户电脑开机之后遇到了系统蓝屏的情况。系统蓝屏问题很多时候都是系统bug，只有通过重装系统来进行解决。那么蓝屏问题如何通过U盘重装新系统来解决呢？来看看以下的详细操作方法教学吧。 准备工作： 1、U盘一个（尽量使用8G以上的U盘）。 2、一台正常联网可使用的电脑。 3、ghost或ISO系统镜像文件（Win10系统下载_Win10专业版_windows10正式版下载-系统之家）。 4、在本页面下载U盘启动盘制作工具：系统之家U盘启动工具。 U盘启动盘制作步骤： 注意：制作期间，U盘会被格式化，因此U盘中的重要文件请注
在应用开发中，有时候我们需要获取系统的设备信息，用于数据上报和行为分析。那在鸿蒙系统中，我们应该怎么去获取设备的系统信息呢，比如说获取手机的系统版本号、手机的制造商、手机型号等数据。1、获取方式这里分为两种情况，一种是设备信息的获取，一种是系统信息的获取。1.1、获取设备信息获取设备信息，鸿蒙的SDK包为我们提供了DeviceInfo类，通过该类的一些静态方法，可以获取设备信息，DeviceInfo类的包路径为：ohos.system.DeviceInfo.具体的方法如下：ModifierandTypeMethodDescriptionstatic StringgetAbiList()Obt
如何将send与+=一起使用？a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法，而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:
需求：要创建虚拟机，就需要给他提供一个虚拟的磁盘，我们就在/opt目录下创建一个10G大小的raw格式的虚拟磁盘CentOS-7-x86_64.raw命令格式：qemu-imgcreate-f磁盘格式磁盘名称磁盘大小qemu-imgcreate-f磁盘格式-o?1.创建磁盘qemu-imgcreate-fraw/opt/CentOS-7-x86_64.raw10G执行效果#ls/opt/CentOS-7-x86_64.raw2.安装虚拟机使用virt-install命令，基于我们提供的系统镜像和虚拟磁盘来创建一个虚拟机，另外在创建虚拟机之前，提前打开vnc客户端，在创建虚拟机的时候，通过vnc
我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止，这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量，我