“`validate_queues”出现shoryuken错误:指定的队列

Question

我使用的是rails "Shoryuken“gem，但当我启动rails服务器时，在我的开发环境中的队列中出现了验证错误，下面是错误：-

gems/shoryuken-2.0.11/lib/shoryuken/environment_loader.rb:172:in ` `validate_queues'：指定的队列"development_worker“不存在(ArgumentError)

我已经使用了以下设置：

config/config yuken.yml

aws:
  access_key_id: <%= ENV["SQS_IAM"] %>
  secret_access_key: <%= ENV["SQS_IAM_SECRET"] %>
  region: <%= ENV["SQS_IAM_REGION"] %>
concurrency: 25  # The number of allocated threads to process messages. Default 25
delay: 0         # The delay in seconds to pause a queue when it's empty. Default 0
queues:
  - ["<%= Rails.env %>_worker", 1]

初始值设定项/shoryuken.rb yuken.rb

def parse_config(config_file)
  if File.exist?(config_file)
    YAML.load(ERB.new(IO.read(config_file)).result)
  else
    raise ArgumentError, "Config file #{config_file} does not exist"
  end
end

config = parse_config([Dir.pwd, 'config/shoryuken.yml'].join('/')).deep_symbolize_keys
Shoryuken::EnvironmentLoader.load(config)

我希望队列应该是特定于环境的。

Answer 1

Ravindra，看看shoryuken的code，你得到了错误，因为你没有创建一个名为development_worker的SQS队列，这是正确的吗？

您需要为每个开发人员创建一个队列，因为shoryuken将在每个开发人员的计算机上运行。如果你不这样做，每台计算机的所有shoryuken进程都将轮询同一队列的消息。假设有两个shoryuken进程，sh1和sh2，分别对应于dev1和dev2机器。如果dev1向dev-queue发送SQS msg，则sh2进程能够轮询dev1发送的消息。

如果你希望避免在亚马逊网络服务中创建队列，你可以看看this。