beanstalkd 큐에서 여러 작업 예약하기

Question

한 번에 beanstalkd 큐에서 여러 작업을 예약 할 수있는 방법이 있습니까?

쿼리 당 최대 10 개의 결과를 반환 할 수있는 외부 API를 요청하고 있습니다. 그들은 매일 할 수있는 요청의 수를 제한합니다. 따라서 요청 당 더 많은 결과가 나옵니다.

이 해결 방법을 사용하고 있으므로 설명서에서이 기능에 대한 언급을 찾을 수 없습니다. 누구든지 이것을 성취 할 수있는 더 좋은 방법을 알고 있습니까? 또는 아마도 beanstalkd보다 직업에 더 적합한 도구일까요?

loop do 
    sleep(0.3) 

    while @beanstalk.tubes[example].peek(:ready) 
    jobs = [] 

    catch(:done) do 
     10.times do |i| 
     if @beanstalk.tubes[example].peek(:ready) then 
      job = @beanstalk.tubes[example].reserve(0) 
      jobs << job.body 
      job.delete 
     else 
      throw(:done) 
     end 
     end 
    end 

    process(jobs) 

    end 
end 

Answer 1

당신은 동시에 삭제하거나 해당 작업을 해제하기 전에 연속 reserve 여러 번 호출하여 여러 작업을 예약 할 수 있습니다.

사용자가 제공 한 코드 샘플을 기반으로, 그것은 대략 이런 식 을 볼 수 있었다 :

loop do 
    timeout = nil 
    jobs = [] 

    begin 
    10.times do |i| 
     jobs << @beanstalk.tubes[example].reserve(timeout) 
     timeout = 0 
    end 
    rescue Beaneater::TimedOutError 
    # nothing to do 
    end 

    process(jobs.map{|j| j.body}) 

    jobs.map do |job| 
    job.delete 
    end 
end