我的问题如下,我使用watchnode来查看到达ftp服务器的csv文件。我解析它是这样的:
payload:{DATE:12344,ID:970005,CONSO:1.344MHw},
topic:"INSERT INTO TABLE test VALUES (12344,970005,1.344)",
filename:/home/.../test.csv,
delay:1500
parts:{index:0,ch:\n,type,string,id:25401f72.a66b,count:null}
_msgid:f3fda651.b7d718
所以我需要将DATE,ID和CONSO放入flexmodbus服务器。我的问题是,无论何时文件出现,它代表1k +对象。 为了让服务器在进入下一个对象之前处理1个对象,我需要添加一些延迟。所以我添加了msg.delay。 但我无法使其与延迟节点一起工作,因此我选择用msg.delay覆盖延迟参数。 有人有想法吗?
msg.delay
不会覆盖delay
节点配置中包含的值。如果要将延迟指定为消息的一部分,则需要在配置中将值保留为空。
此外,延迟是从消息到达delay
节点的时间开始,而不是在每条消息之间。如果要将消息分隔开,则需要在速率限制模式下使用delay
节点。