我有一个REST，它由不同的资源组成。其中一些资源也被编入索引并在ES中保持同步，我正在实现一个队列系统，以异步方式管理这些操作。我决定选择Beanstalkd作为排队系统。对于每个资源，我将有一个不同的管，我将分裂索引工作的资源。例如，我将有像"index_users“、"index_posts”这样的管道，它们将接收带有资源in的作业，以便在ES中进行索引：对
浏览 2提问于2014-11-27得票数 0
1回答
我正在尝试使用Logstash使用文件输入、json过滤器和elasticsearch输出来解析一条大消息。在99%的情况下，这种方法工作得很好，但是当我的一条日志消息太大时，我会得到JSON解析错误，因为初始消息被分解成两个部分无效的JSON流。此类消息的大小约为40,000+字符长。此外，大多数数据都在一个数组中，所以虽然我可以使用脚本()更新Elasticsearch记录的数组，但我不能在Logstash中这样做。数据记录如下所示：
{ "variabl
浏览 8提问于2015-05-02得票数 5
所谓“某些东西”，我指的是输入数据，这可能会导致函数发生意外的行为，主要是其他类似的事情，其目的是测试函数的“负面”条件。顺便问一下，什么名字也用来表示“积极”的东西？
浏览 3提问于2013-08-12得票数 0
我有一个传入的数据流，作为单独的消息发送到RabbitMQ。
我想将这些信息发送到需要一批消息的服务中。当我有一批1000条消息或5秒过期时，我需要将请求发送到服务。我确实看过方法doReceiveAndExecute(BlockingQueueConsumer consumer)和"receiveTimeout"，但是由于这个变量在事务循环中，所以我可以在每次消息中等待我目前有一个通道感知监听器，它将消息批处理到一个大容量
浏览 2提问于2015-12-24得票数 2
回答已采纳
2回答
哪些NewSQL发行版适合处理数据仓库和空间查询？(MemSQL，VoltDB，NuoDB，什么？以及原因)
浏览 1提问于2018-11-27得票数 0
我正在尝试用tcp开发一个具有不同大小消息的实时数据流应用程序。在故障注入测试中，发现当网络延迟小于150 ms时，100字节的消息比500字节的消息更容易丢失。然而，在高网络延迟的情况下，大消息(超过500个字节)的丢失率增加到0.3%以上，而较小消息的丢失率仍然保持在%0.1。有人能说出为什么会发生这种事吗？提前谢谢你。
浏览 0提问于2020-05-02得票数 0
回答已采纳
1回答
我已经安装了下面的1.Elasticsearch 1.0.0 \2. 3.MongoDB 2.4.9 \3.3.MongoDB插件2.0.0\ 4.4.Mapper附件\16:49:58,442org.elasticsearch.river.mongodb.MongoDBRiverBulkProcessor大容量处理器2014-05-13失败NumberFormatException[用于输入字符串："(303) 427-9484“；：索引dava
浏览 4提问于2014-05-13得票数 0
我正在使用带有firebase的库在flutter中进行推送通知。文档中说，myBackgroundMessageHandler是在应用程序在后台调用的。但这并没有发生。_fcm.configure()
static Future<Map<S
浏览 0提问于2020-11-12得票数 2
通过spring message listener在1小时内处理大容量(320万条消息)的最佳方式是什么？在监听消息的同时如何处理异常?在此期间如何写入数据库？
浏览 1提问于2015-10-25得票数 0
2回答
我正在开发一个用java编写的微服务，它将消息放到一个队列中。由于我使用的是JMS，因此无法使用消息分段来处理大消息。我想知道，消息分组是否也允许我处理大消息？所谓大消息，我指的是比MaxMsgLength更大的消息。
浏览 2提问于2021-01-29得票数 0
我们在一个特定的属性中有非常大的消息，就像这样 optional string datavalue=1;上面的数据值是非常大的文本消息。但是，我注意到当我将此消息发送到wire (通过REST)时，需要更长的时间才能得到响应。总是比XStream长两倍。我认为这可能来自于序列化时间。从谷歌文档来看，它说Protocol buffers不是为处理非常大的消息而设计的，尽管它可以处理</e
浏览 0提问于2010-07-30得票数 1
我使用Spring JMS Listener从AMQP队列中读取消息。如果消息处理失败，则使用事务处理会话来处理失败。失败时，将消息重定向到另一个队列。尝试使用并发选项，但无法使用它，因为我的消息处理需要按顺序挑选消息。
在队列中处理大约5000条消息需要大约30分钟。从队列中读取消息并保存到数据库中。destination="queueName&quo
浏览 0提问于2014-05-03得票数 2
也许我没有正确地使用R标记，但是我的第一行代码加载了一个非常大的数据集，然后进行分析。每次我编织pdf看看它是什么样子，它再次运行所有的代码，这需要相当长的时间。数据已经存储在环境中了，那么有什么方法可以让R不再运行所有代码，而是在修改后显示pdf呢？
浏览 0提问于2016-09-20得票数 0
回答已采纳
1回答
异步消息测试
、、、
问题陈述如下我正在开发自动化测试框架。我正在寻找一种方法，让测试类知道数据处理的下一步已经订阅了唯一同一性。问题是当我们运行大量的测试用例时，会花费大量的时间。
我已经读过Awa
浏览 1提问于2011-09-08得票数 0
3回答
我正在处理非常大的分隔文件。这些文件已经过预处理，以确保字段和行分隔符有效。偶尔会处理不符合TSQL约束的行(通常是数据类型问题)。在这种情况下，‘修复’输入数据不是一个选项。大容量插入在SSMS中完成，严重级别为16的错误消息记录到每个失败行的“消息”窗口中。尝试通过C# SqlCommand类执行此代码会在生成第一条严重级别为16的错误消息时引发异常，从而导致批处理失败。有没有一种方法可以通过C
浏览 2提问于2012-07-20得票数 3
我使用ODBC从数据库中查询表：Q = "SELECT * FROM TestDescription WHERE NProduct = " ++此函数将返回一个包含所有数据库数据的元组。将此消息发送到另一个进程：它可以很好地处理少量的行数，但是如果行数非常大，比如说大于一百万行，情况会怎样呢？erlang还能使用它吗？
浏览 0提问于2012-03-16得票数 3
回答已采纳
1回答
例如，假设大约有10000条记录从WCF服务发送到调用客户端。根据WCF，我们可以在web.config文件中设置响应缓冲区的大小。我想一次得到1000条记录的回复。在不对web.config文件进行任何更改的情况下，如何实现这一点？在这方面需要帮助。
浏览 1提问于2013-05-08得票数 0
回答已采纳
1回答
如果将SQS侦听器参数更改为String，则会收到消息："UnsubscribeURL" : "https://sns.us-west-2.amazonaws.com/?
浏览 9提问于2022-03-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
