腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
NiFi
中
的
重试
和
失败
队列
优先级
排序
http
、
error-handling
、
apache-nifi
我在
NiFi
有一个
队列
,其中包含将通过API query (invokeHTTP)处理
的
项。这些项目可以被处理,并返回正确
的
答案和数据(状态200),它们无法找到(状态404),也会
失败
(状态500)。但是,在状态为404
和
500
的
情况下,可能会发生假阴性,因此,如果我再次查询给出错误
的
相同数据,它将返回状态200。但在某些情况下,确实存在故障,并且不是假阴性。 ? 所以我创建了一个
重试
和
失败
浏览 55
提问于2020-10-13
得票数 1
2
回答
如何为各个流文件指定
优先级
属性?
apache-nifi
我需要在PrioritizeAttributePrioritizer中使用
NiFi
。如果我收到10个流文件,那么我需要将每个流文件
的
优先级
值设置为唯一。之后,指定
队列
配置必须是PrioritizeAttributePrioritizer。如何为独立
的
流文件设置
优先级
值,或者在
Nifi
中
哪个优先程序适合我
的
情况?
浏览 6
提问于2017-03-01
得票数 4
回答已采纳
4
回答
如何使用SQS(Amazon简单
队列
服务)实现
优先级
队列
python
、
boto
、
priority-queue
、
amazon-sqs
当msg
失败
时,我遇到了一种情况,我希望使用python包来重播
优先级
最高
的
msg,这样他就会首先被选中。如果我没有错,SQS
队列
不支持
优先级
队列
,所以我想实现一些简单
的
东西。重要注意事项:当msg
失败
时,我不再有消息对象,我只保留消息对象,这样我就可以删除消息(如果超过x
重试
)/更改超时可见性,以便将它推回
队列
。 谢谢!
浏览 11
提问于2015-03-10
得票数 18
回答已采纳
1
回答
在maxReceiveCount (死信
队列
)下
重试
的
消息
的
优先级
是多少?
amazon-web-services
、
aws-lambda
、
amazon-sqs
我有一个FIFO
队列
,它触发一个lambda,当lambda函数成功时,它将自动删除FIFO
队列
中
的
消息,但是当lambda
失败
时,它会在maxReceiveCount.Where maxReceiveCount设置为3之前将消息发送到死信
队列
。因此,
失败
的
消息将在发送到死信
队列
之前
重试
三次,但是当它是FIFO
队列
时,它将完成对消息
的
3次
重试
,然后转移到下一条消息
浏览 2
提问于2021-05-12
得票数 0
1
回答
针对MSMQ
中
不同消息
的
不同
重试
策略
message-queue
、
msmq
我们需要一个API,它允许通过MSMQ消息
队列
进行异步更新,这是我正在组合
的
,这将允许使用API
的
开发人员为每个消息指定不同
的
重试
策略。因此,一个高
优先级
的
客户端系统,例如销售系统,将提交所有的消息,每次发送尝试5次(
重试
)
和
15分钟,而一个低
优先级
的
客户端系统,例如后端邮件拍摄系统,将允许用户更新他们
的
营销偏好,提交消息,3次
重试
和
每次尝试之间
浏览 4
提问于2013-08-05
得票数 2
回答已采纳
1
回答
失败
时
的
NiFi
块流文件
apache-nifi
我为自己设置了一个处理器故障关系,当一个流文件进程
失败
时,我希望它回到传入
队列
的
顶部并
重试
,同时我向管理员发送电子邮件通知,在故障解决后,被阻止
的
流文件可以处理聚集。
NiFi
是否支持这一点?
浏览 0
提问于2019-06-11
得票数 0
3
回答
当
NiFi
不适用时,如何管理EnforceOrder?
sorting
、
apache-nifi
我收到
的
实时数据可能会出现故障,有些数据比其他数据来得晚。对于以后
的
事件处理,我需要重新
排序
流文件流,并且我正在尝试查看在
NiFi
中
是否可能这样做。我对EnforceOrder
的
理解是,它需要一个增量整数作为flowfile属性,并且知道起点。 当我处理实时流
的
时候,我没有一个起点,所以我不知道如何让它发挥作用。我所拥有的是我可以提取
的
数据
中
的
时间戳,转换为linux时间戳,并在“
优先级
”属性<em
浏览 6
提问于2022-02-23
得票数 0
回答已采纳
1
回答
在多个NodeJS服务器之间传递数据
node.js
这将检查数据库
中
的
所有计划任务,并检索正在运行
的
报告
的
存储参数。制作完pdf后,他们会转到一个最终
的
电子邮件应用程序,该应用程序会将
浏览 4
提问于2015-08-14
得票数 0
1
回答
Spark在yarn杀死执行器后不断重新启动执行器
apache-spark
、
hadoop-yarn
spark作业在较低
优先级
队列
中
运行。当更高
优先级
的
任务到来时,它
的
容器就会被抢占。然而,它在被杀死后立即重新启动容器。
优先级
更高
的
应用程序会再次杀死它们。因此,应用程序陷入了这种僵局。here讨论了执行器
的
无限
重试
。在日志中找到下面的痕迹。因此,我设置
的
任何
重试
次数似乎都不会被考虑。是否有一个标志来指示应该对executor
中
的
所有
失败
浏览 131
提问于2019-05-21
得票数 4
3
回答
未
排序
优先级
队列
data-structures
我已经被误导了一点,所以我有点confused.This是什么,我已经理解为一个未
排序
的
优先级
,有人能确认一下吗?未
排序
的
优先级
队列
是指根据
优先级
(即
队列
中
的
最小值)在
队列
末尾插入
和
删除元素
的
队列
。
浏览 1
提问于2013-01-03
得票数 0
回答已采纳
1
回答
对Sedgewick“算法”堆
排序
章节注释
的
澄清(第4版,第2.4章)
algorithm
、
heap
、
priority-queue
关于基于
优先级
队列
的
实现
的
的
Q&A部分(p.328)有以下段落(让我们关注
优先级
队列
堆,而不是堆
排序
): 在一些数据处理示例
中
,如TopM
和
Multiway,数据量太大,无法考虑
排序
(甚至存储在内存
中
)。如
浏览 3
提问于2015-09-14
得票数 4
回答已采纳
1
回答
activemq不断
重试
错误消息,并且不拾取新消息
queue
、
activemq
、
message-queue
它设置为在
重试
周期内每10分钟
重试
一次
失败
的
消息。谢谢你
的
帮助。编辑:我能够解决这个问
浏览 2
提问于2012-07-09
得票数 0
1
回答
NiFi
1.0.0 -
队列
的
自定义
优先级
apache-nifi
是否有一种为
队列
添加自定义
优先级
的
方法?还是有一种方法来延长排队
的
行为? 如果没有,将来会在
NiFi
中
添加吗?
浏览 3
提问于2016-11-19
得票数 0
回答已采纳
2
回答
您能使用一种方法将项添加到三个不同
的
优先级
队列
实现
中
吗?
java
、
generics
我正在为大学做一项作业,其中涉及
优先级
队列
的
自定义实现。
队列
中
的
每一项都是存储元素及其
优先级
的
Node<E> (E,p)。整个字段应该是ArrayList<Node<?>>类型
的
,这三个实现将是- 未
排序
队列
,在结束时添加项,并按照最长类型ArrayList<Node<String>>
队列
中
的
浏览 5
提问于2013-01-27
得票数 1
2
回答
在Java
中
实现
优先级
队列
自定义比较器
的
问题
java
、
comparator
、
priority-queue
请原谅我对Java
中
优先级
队列
和
比较器
的
理解。但是,我无法为下面的情况想出一些东西:由于我对
优先级
队列
知之甚少,所以我尝试实现它,但我只能在asc或desc值xx中进行
排序
,这不是所需
的
。我
的
方法是 将文件名列表放在
优先
浏览 5
提问于2020-08-18
得票数 0
回答已采纳
1
回答
Apache
Nifi
中
的
工作流数据意外消失
apache-nifi
我
的
流工作正常,但是一个小时后流
的
数据就消失了。我已经将堆大小内存从100mb减少到8g它不工作,我
的
cpu使用率增加到500%,然后我
的
流
的
数据消失了。我
的
意思是所有处理器
的
输入/输出都变为零,我附加了我
的
流。有谁有解决方案吗?我
的
系统配置:处理器2.3 GHz英特尔酷睿i7这是我
的
flow
的
日志 这是我丢失数据并删除co
浏览 0
提问于2019-02-18
得票数 2
1
回答
Apache
NiFi
-使用多个FlowFiles作为处理器
的
输入
apache-nifi
产生一个单一
的
输出。我希望自己编写一个处理器来执行设置逻辑,但是否有可能处理不同来源
的
多个流文件并同时处理它们?
浏览 2
提问于2017-02-10
得票数 3
回答已采纳
3
回答
Apache
Nifi
文件被卡在
队列
中
。
apache-nifi
流文件被卡在
队列
中
(按属性进行负载平衡),下一个下游处理器(MergeRecord
和
CSVReader
和
CSVRecordSetWriter)不会读取。从
Nifi
来看,流文件似乎在
队列
中
,但是当试图列出
队列
时,它会说“
队列
没有流文件”。尝试清空
队列
也会给出确切
的
消息。
Nifi
日志没有任何与处理器相关
的
异常。
队列
中大约有80个流文件。我试过以下动作
浏览 0
提问于2019-05-09
得票数 2
2
回答
二进制堆
的
所有用途
c
、
data-structures
、
language-agnostic
、
priority-queue
、
binary-heap
定义:执行情况: 为了实现
优先级
队列<
浏览 3
提问于2017-01-04
得票数 0
1
回答
带有MS-SQL: update语句挂起
的
apache处理器
sql-server
、
apache-nifi
系统: 2016,Apache
NiFi
1.11.4 但是没有日志条目,没有错误消息,在成功、
失败
或
重试
方面没有进一步
的
问题。
浏览 2
提问于2020-04-13
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
什么是Java PriorityQueue?
一种异步延迟队列的实现方式
RabbitMQ 核心概念(交换机、队列、路由键),队列类型等介绍
Java并发基础:PriorityBlockingQueue全面解析!
Volley 源码解析
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券