腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Logstash:
处理
大
消息
、
、
、
我正在尝试使用Logstash使用文件输入、json过滤器和elasticsearch输出来解析一条
大
消息
。在99%的情况下,这种方法工作得很好,但是当我的一条日志
消息
太大时,我会得到JSON解析错误,因为初始
消息
被分解成两个部分无效的JSON流。此类
消息
的大小约为40,000+字符长。此外,大多数
数据
都在一个数组中,所以虽然我可以使用脚本()更新Elasticsearch记录的数组,但我不能在Logstash中这样做。
数据
记录如下所示: { "variabl
浏览 8
提问于2015-05-02
得票数 5
1
回答
SimpleMessageListenerContainer
大
容量
消息
处理
、
、
、
、
我有一个传入的
数据
流,作为单独的
消息
发送到RabbitMQ。 我想将这些信息发送到需要一批
消息
的服务中。当我有一批1000条
消息
或5秒过期时,我需要将请求发送到服务。我确实看过方法doReceiveAndExecute(BlockingQueueConsumer consumer)和"receiveTimeout",但是由于这个变量在事务循环中,所以我可以在每次
消息
中等待我目前有一个通道感知监听器,它将
消息
批
处理
到一个
大
容量
浏览 2
提问于2015-12-24
得票数 2
回答已采纳
1
回答
在中插入没有值的
大
容量
、
如何从应用程序中查看哪些
数据
库接受?
浏览 0
提问于2013-03-13
得票数 7
1
回答
Flutter - myBackgroundMessageHandler从不在推送通知中调用
、
、
、
我正在使用带有firebase的库在flutter中进行推送通知。文档中说,myBackgroundMessageHandler是在应用程序在后台调用的。但这并没有发生。_fcm.configure() static Future<Map<S
浏览 0
提问于2020-11-12
得票数 2
1
回答
如何在spring message listener中
处理
大量
消息
、
通过spring message listener在1小时内
处理
大
容量(320万条
消息
)的最佳方式是什么?在监听
消息
的同时如何
处理
异常?在此期间如何写入
数据
库?
浏览 1
提问于2015-10-25
得票数 0
2
回答
消息
分组可以做
消息
分段做的事情吗?
、
、
、
、
我正在开发一个用java编写的微服务,它将
消息
放到一个队列中。由于我使用的是JMS,因此无法使用
消息
分段来
处理
大
消息
。我想知道,
消息
分组是否也允许我
处理
大
消息
?所谓
大
消息
,我指的是比MaxMsgLength更大的
消息
。
浏览 2
提问于2021-01-29
得票数 0
2
回答
协议缓冲区
处理
非常
大
的字符串
消息
?
、
我们在一个特定的属性中有非常
大
的
消息
,就像这样 optional string datavalue=1;上面的
数据
值是非常
大
的文本
消息
。但是,我注意到当我将此
消息
发送到wire (通过REST)时,需要更长的时间才能得到响应。总是比XStream长两倍。我认为这可能来自于序列化时间。从谷歌文档来看,它说Protocol buffers不是为
处理
非常
大
的
消息
而设计的,尽管它可以
处理</e
浏览 0
提问于2010-07-30
得票数 1
3
回答
TSQL
大
容量插入行错误导致C#异常
、
、
、
、
我正在
处理
非常
大
的分隔文件。这些文件已经过预
处理
,以确保字段和行分隔符有效。偶尔会
处理
不符合TSQL约束的行(通常是
数据
类型问题)。在这种情况下,‘修复’输入
数据
不是一个选项。
大
容量插入在SSMS中完成,严重级别为16的错误
消息
记录到每个失败行的“
消息
”窗口中。尝试通过C# SqlCommand类执行此代码会在生成第一条严重级别为16的错误
消息
时引发异常,从而导致批
处理
失败。有没有一种方法可以通过C
浏览 2
提问于2012-07-20
得票数 3
1
回答
Erlang如何
处理
非常
大
的
消息
?
我使用ODBC从
数据
库中查询表:Q = "SELECT * FROM TestDescription WHERE NProduct = " ++此函数将返回一个包含所有
数据
库
数据
的元组。将此
消息
发送到另一个进程:它可以很好地
处理
少量的行数,但是如果行数非常
大
,比如说大于一百万行,情况会怎样呢?erlang还能使用它吗?
浏览 0
提问于2012-03-16
得票数 3
回答已采纳
1
回答
WCF,逐部分
数据
传输
例如,假设大约有10000条记录从WCF服务发送到调用客户端。根据WCF,我们可以在web.config文件中设置响应缓冲区的大小。我想一次得到1000条记录的回复。在不对web.config文件进行任何更改的情况下,如何实现这一点?在这方面需要帮助。
浏览 1
提问于2013-05-08
得票数 0
回答已采纳
1
回答
侦听器接收空POJO
、
、
如果将SQS侦听器参数更改为String,则会收到
消息
:"UnsubscribeURL" : "https://sns.us-west-2.amazonaws.com/?
浏览 9
提问于2022-03-04
得票数 0
1
回答
如何从NiFi工作流出发在GCP发布子主题上发布实时
消息
、
、
上下文:问题陈述: 由于
消息
处理
模块和实时
数据
存储正在转移到GCP,因此需要发布/推送
消息
,从“假设的Kafka主题和Solace队列到GCP主题”。
浏览 1
提问于2018-10-06
得票数 0
1
回答
用于
大
消息
大小的ActiveMQ持久性存储
、
如果生产者正在发送
大
消息
大小的
消息
(比方说120MB)。kahadb和levelDB是如何
处理
这样的
消息
的。leveldb:默认情况下,存储
消息
数据
的默认大小为100mB。在此之后会发生滚动。如果
消息
大于100mB。它是如何<em
浏览 1
提问于2014-11-03
得票数 0
2
回答
NService总线
消息
未按顺序到达(即发送时)
、
我们使用NService总线进行
消息
传递framework.Sometime
消息
不是按标准的顺序到达的,发送.Sometimes最后一条
消息
的顺序是先来,然后是第一条
消息
。 请帮帮我谢谢
浏览 0
提问于2010-05-26
得票数 0
1
回答
通过WCF发送二进制
数据
:二进制与MTOM编码
、
、
、
、
我在WCF以及通过WCF发送二进制
数据
方面的知识有限,所以这个问题可能有些初级。我想知道用BinaryMessageEncodingBindingElement和MtomMessageEncodingBindingElement发送
数据
的区别。还有一个小问题:带附件的
消息
和MTOM
消息
是一回事吗?
浏览 0
提问于2011-07-27
得票数 2
回答已采纳
1
回答
数据
库性能:表中的更多列如何影响设计/开发/性能
、
、
、
、
我有一个程序可以捕获许多不同类型的结构化
消息
。我需要将
消息
保存到
数据
库中。论坛对设计和性能的看法是:(b)对每种
消息
类型使用一个表,因此对于新
消息
类型,将向
数据
库添加一个新表。在性能方面,我指的是搜索所有
消息
(即搜索一个表与跨连接表进行
浏览 0
提问于2014-08-01
得票数 0
回答已采纳
2
回答
Azure函数错误
处理
?
、
我已经编写了一个Azure函数,它
处理
来自Event Hub的
消息
并将
消息
写入Azure Table。 Azure函数中的错误
处理
到底是如何工作的?我如何发出
处理
消息
失败的信号,以确保
消息
在未正确写入Azure表的情况下不会从事件中心永久删除?
浏览 2
提问于2017-02-15
得票数 1
1
回答
Kafka幂等生产者成为延迟瓶颈
我们在kafka producer中使用幂等生产者模式,因为我们希望
数据
只存储一次,并且在代理中按顺序存储。这种速度变慢了,因为对broker的最大运行请求只能是5。另外,在producer,consumer和kafka broker运行的同一台机器上,我看到100k
消息
突发的平均延迟约为20ms到30ms。此外,报文是金融交易/报价报文,因此我们不希望有任何
数据
丢失或差距。
浏览 25
提问于2019-03-13
得票数 0
1
回答
用于混合类型(json和大
数据
对象)的类型转换
、
我想在前端web应用程序和
数据
处理
管道之间代理混合内容
消息
。特别是,我需要发送一个
数据
三元组,包括: 我在1处查看Spring文档,了解可能的输入/输出转换。但是,我希望避免将这么
大
的
数据
编码给json。但是,除了将
消息
三重分
浏览 1
提问于2015-07-10
得票数 0
1
回答
以GB为单位的
消息
大小的Kafka性能
我知道当
消息
大小从字节到几MB时,kafka在
处理
更大的
消息
时表现得更好。但是,当
消息
大小从千字节到千兆字节时,上述相关性是否成立?基本上,我有一个生产者吐出
大
消息
的用例-我不能将
大
消息
分解成小
消息
,因为我需要自动
处理
它。
浏览 4
提问于2014-12-05
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
数据处理:大物实验的终极神器
数据分析,10大数据可视化设计细节处理!
python多进程-kafka异步消息处理
消息称苹果AI服务器将使用“机密计算”技术来处理数据
大数据处理必备的十大工具!
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券