问题标签 [apama]

我在金融部门工作，我们组织中有一个产品主要用于监控各种交易事件以生成警报。该产品是用 C# 开发的，但为了跟踪和引发有意义的事件/警报，系统的另一个模块是在 Progress 的 Apama 中开发的。由于我对产品了解不多，我怀疑为什么事件和警报处理需要另一个框架。请指导。

谢谢你。

我在 Apama 4 中构建了 CEP 项目，现在正在迁移到 Apama 5.1。但我是新手，甚至无法弄清楚如何打开旧项目。我浏览了pdf，但没有太多帮助。请有人指导我如何开始。

与 Apama 安装一起存在许多示例，但是我无法确定您是否只能比较事件中的某些参数，而不是整个事件。

例如，如果捕获以下内容：

并期待

然后我只想比较参数 1 和 3，目前是否可以从 apama/pysys 框架中进行比较？

更进一步，与日志文件比较时是否可以使用相同的功能？

我们正在使用 pysys 来测试 apama 并希望提高性能。阻碍我们的一件事是我们发出 7 个 engine_receive 来监控 7 个不同的通道到 7 个不同的文件中。

问题是启动这 7 个接收需要大约 10 秒。

我尝试使用 python 线程开始调用 pysys 并行中的接收方法，但在这种情况下没有任何反应。

有人知道改善这一点的方法吗？

很多谢谢

需要知道是否有可能（并且会产生影响）在 CEP（单核化器）中实现 b 树。我们面临的问题是我们不能每秒处理超过 1000 条消息。我认为这是由解决方案的实施方式引起的。

我们想检测一个位置是否在一个区域内，并在进入、停止、开始和离开区域时引发一个事件。我们现在只有大约 500 个区域，每秒最多 1000 个位置想要增加区域。现在正在备份消息。我认为解决方案是在 CEP 中引入 B 树。所以首先你会检测一个位置是否在头部区域，然后查询位置是否在这个头部区域内的区域中。我认为这可以提高性能，但不确定是否可行或明智。

有没有人有任何经验？

我正在编写一个应用程序，它可以接收从不同来源进入系统的两种类型的事件。我想有一个上下文来处理它们中的每一个。请参阅下面的代码：

我的问题在于我希望将Cascade()事件推送到处理队列的前面，因为它是一个优先级。但是当我尝试执行以下操作时：

它给了我一个错误 - 我如何将事件作为优先级从一个上下文路由到另一个上下文？

我知道我可以使用 PySys 来测试我的应用程序，我已经编写了一个带有执行和验证的 run.py 文件，但是当我运行它时似乎什么也没发生。我尝试添加一个 init 函数并从那里打印只是为了查看我的测试类是否正在被实例化，但我没有得到输出。我错过了什么吗？

我使用 pyhton run.py 来执行它。

我正在尝试定义一个监视器，在该监视器中接收事件，然后在多个上下文中处理它们（如果我理解正确，大致等同于线程）我知道我可以写

这将在新的上下文中运行该操作。

但是，我想要一个动作，当它进入我的监视器时，它会响应一个事件：

我可以on all以使用特定上下文的方式定义 my 吗？就像是

如果不是，在 Apama EPL 中定义它的最佳方法是什么？当它们到达时，我是否可以有多个上下文处理相同的事件，循环方式？

我正在尝试在连接链中使用 Mapper 编解码器来转换如下所示的 JSON 对象：

到 EPL 类型。对我来说，它看起来像一个序列序列，所以我使用了

但这给了我错误

为此我应该如何使用 Mapper 编解码器有什么想法吗？

我正在尝试在 Apama 中使用 Python 插件。不幸的是，我在启动相关器时总是收到以下错误消息。

无法初始化相关器：无法初始化 Python 插件。将 AP_PYTHONHOME 设置为 python 的位置

如果我在本地对其进行测试，该应用程序将正常工作。但是，一旦我切换到生产系统并尝试通过.mon文件调用 Python 应用程序，就会发生此错误。

谁能告诉我为什么它不能初始化 Python？

Apama 使用以下命令配置和启动。