问题标签 [aggregator]

我有一些问题。我是 ESB 的新手，我只是尝试 WSO2 ESB。我想尝试有关 wso2 ESB 聚合器的示例，以聚合两个 Web 服务。

http://docs.wso2.org/display/IntegrationPatterns/Aggregator

我已经完成了所有步骤。但我得到一些错误。

==================

=============

任何人都可以帮助我吗？

谢谢。

我是一名新手程序员，了解 HTML、CSS 和一些语言的基础知识。我想创建一个网站，将新闻与原始文章的链接聚合在一起，但不仅让我的网站使用西班牙语，而且能够在重定向时为用户自动翻译英文新闻链接。

翻译我的网站是很容易的部分，但为用户翻译的英文网站是我有疑问的地方。我尝试使用谷歌翻译并且它确实有效，但是当你被重定向时，用户必须首先在网站被翻译之前更改设置......并且这些说明或下拉菜单是英文而不是西班牙文。

1. HTML、CSS 是否足以构建这样的东西，还是我需要使用 PHP 或其他？
2. 有没有一种方法可以自动为用户翻译网站而无需他们先做某事？

我们使用 Graphite 已经有一段时间了，最​​近将一些指标的来源从 statsd 更改为 yammer/codahale-metrics。由于我们的指标通常是从许多不同的服务器发送的，因此我们设置了 Graphite 自己的聚合器来为我们处理这些。

现在的问题是单个服务器的统计数据显示并且表现得很好，但汇总的统计数据将始终只在最后一小时左右是正确的。这意味着旧的聚合值会在一段时间后以某种方式进行修改。这是它的样子： 绿线只是应该聚合的指标上的 sumSeries，蓝线是聚合器生成的。请注意，两条线仅在过去一个小时内是如何协调的。

当然，我们已经研究了存储/聚合/保留规则，但它们都是非常基础的，应该平等地涵盖所有指标（基本上甚至在 1 小时后就不会生效）：

存储架构.conf

存储聚合.conf

实际聚合器的配置可能是这里的盲点，因为我们找不到任何真正详细的文档，并且大部分都保持原样。

碳.conf

我是 Mule 的新手，这就是我想要做的。1) 调用出站休息服务 A 2) 循环遍历结果并调用休息服务 B 3) 汇总来自服务 B 的结果并返回有效负载。这是我想出的，但这个流程是从服务 A 返回结果。如何忽略来自 A 的结果并从 B 返回聚合结果？我在 for 循环中添加了记录器，可以看到 B 的响应，但不确定如何将结果返回给用户？我需要自定义聚合器吗？

感谢任何帮助！

我对路由的理解（在 Apache Camel 术语中）是它表示从一个端点到另一个端点的数据流，并且它会在对数据执行 EIP 类型操作的过程中停止在各个处理器处。

如果这是对路线的正确/公平评估，那么我正在建模一个我认为需要在同一条路线内有几条路线的问题CamelContext（我使用的是 Spring）：

1. 路线 1：从 Source-1 中提取数据，对其进行处理，将其转换为 a List<SomePOJO>，然后将其发送到聚合器
2. 路线 2：从 Source-2 中提取数据，对其进行处理，还将其转换为 a List<SomePOJO>，然后将其发送到聚合器
3. Route 3：包含一个聚合器，等待它List<SomePOJO>从Route 1 和 Route 2 接收到 a ，然后继续处理聚合列表

事情是这样的：两个List<SomePOJO>s 需要同时到达聚合器，或者更确切地说，聚合器 bean 必须等到它从两个路由接收到数据之前，它才能将 2 个列表聚合为一个List<SomePOJO>列表并将聚合列表发送到3号公路的其余部分。

到目前为止，我有以下伪编码<camelContext>：

然后在Java中：

我的问题

1. 我的基本设置正确吗？换句话说，我direct:aggregator是否正确使用端点将数据从聚合器发送出去route-1和发送route-2到route-3聚合器？
2. 我的聚合器会按照我期望的方式工作吗？假设extractor1bean inroute-1只需要 5 秒运行，但extractor2bean inroute-2需要 2 分钟运行。在 t=5 时，聚合器应该从那里接收数据extractor1并开始等待（2 分钟）直到extractor2完成，然后将其余数据提供给聚合器。是的？

我有以下骆驼路线：

如您所见，它聚合<aggregator/>接收到的前 500 条消息，或 1 分钟间隔内的所有消息，然后将聚合消息发送到名为postProcessor.

你可以这样想这个聚合逻辑：

或者在伪代码中：aggregateUntil(weHave500Message() || 1minHasElapsed()). 我想将此逻辑更改为：

或者，再次以伪代码：aggregateUntil(weHave500Message() || 1minHasElapsed() || messageHasProperty("fireNow", "true")).

换句话说，聚合直到满足 3 个条件中的任何一个。有什么想法可以实现吗？我有一种感觉completionPredicate，也许我可以解决这个问题eagerCheckCompletion，但在这里看不到森林。

我使用以下流程来聚合来自 JMS 主题的消息。

当消息负载非常高时，抛出以下异常：

我使用 Mule EE 版本 3.4.0。是否有人对此有解决方案，或者可以忽略它，因为它与 ExpiringGroupMonitoringThread 相关？感谢您的回复！

我在 Mule EE 3.4.1 中遇到以下异常。我觉得这与同一个问题有关。

当使用大量数据时，我们会在关联聚合器之后丢失消息。这些异常是否与丢失的消息有关？

我正在寻找一个 wordpress 插件，我可以在其中添加文章 URL 并在编辑新帖子时复制整篇文章（包括图像）。

我已经安装了很多 rss 聚合器、导入器等，但它们都没有这样做。

需要明确的是，我不想复制整个网站，我只想输入一个 URL 并将所有内容和图像导入到我的新帖子中。

我正要自己写，但我想知道是否有任何宝石/库可以用作聚合器/直方图

我的目标是根据匹配键总结值：

应该对每个唯一键的值求和并返回["fish","42"]和["meat","57"] 。我必须聚合的文件比较大，大约 4gb 由 tsv 键/值对组成的文本文件。我的目标是尽量不使用临时文件，以免太机器上有很多空间，所以我想知道是否已经存在类似已经优化的东西，我在 github 上找到了一个名为“histogram”的 jeb，但它并没有真正包含我需要的功能 Thx

我们有目前的情况。我使用 Apache Camel，为小型交换拆分大文件（使用拆分器，见下文）并验证它们。然后我需要聚合消息，但我使用聚合器，它需要设置编译大小或其他。我可以在不设置限制的情况下汇总当前文档中的所有交换吗？

我的路线：

要设置聚合器，我用来设置交换次数或时间，但我不知道会有多少次交换。