sqs源上的Siddhi轮询间隔不起作用答案

【问题标题】：Siddhi polling interval on sqs source not workingsqs源上的Siddhi轮询间隔不起作用
【发布时间】：2019-08-13 18:09:05
【问题描述】：

您好，我是 Siddhi 的新手，并且已经使用 SQS 源设置了一个应用，我尝试将轮询间隔设置为 10 秒，将最大消息数设置为 1。

但是，我只是得到一个恒定的消息流，就好像它只是忽略了这些值一样。

这是我删除敏感信息的代码

@App:name('SQS TEST')
@App:description('Description of the plan')

@source(type = 'sqs', 
    queue = '',
    access.key = '',
    secret.key = '',
    region = '',
    polling.interval = '10000',
    wait.time = '20',
    max.number.of.messages = '1',
    delete.messages='false', 
    number.of.parallel.consumers = '1',
    @map(type = 'json', fail.on.missing.attribute='false', enclosing.element='$.entries',
        @attributes(val1 = 'val1', val2='val2')))

define stream inStream (val1 string, val2 string);

@sink(type = 'log', prefix = 'Cafe Feed:')
define stream log_received (val1 string, val2 string);

from inStream
select val1,val2
insert into log_received;

任何帮助将不胜感激，谢谢。

【问题讨论】：

标签： amazon-sqs siddhi

【解决方案1】：

SQS 源的默认行为是从 sqs 队列中提取消息，直到队列中没有消息为止。亚马逊 API 允许开发人员定义每个请求检索到的消息数，上述 'max.number.of.messages' 公开了该属性.

要解决此问题，您可以将队列的可见性超时修复为更大的值，以停止返回消息或在从队列中读取消息后删除消息。

【讨论】：