tweaking things a bit to add a basic batch worker using sidekiq
parent
7d49e80dba
commit
c716d7cf27
@ -0,0 +1,6 @@
|
|||||||
|
#!/bin/sh
|
||||||
|
CONCURRENCY_LEVEL=${CONCURRENCY:-1}
|
||||||
|
|
||||||
|
echo "Concurrency set to : ${CONCURRENCY_LEVEL}"
|
||||||
|
echo ""
|
||||||
|
bundle exec sidekiq -r ./worker.rb -c $CONCURRENCY_LEVEL
|
@ -0,0 +1,3 @@
|
|||||||
|
#!/bin/sh
|
||||||
|
echo "the port is : ${PORT}"
|
||||||
|
bundle exec puma -t 5:5 -p ${PORT:-8080} -e ${RACK_ENV:-development}
|
@ -0,0 +1,15 @@
|
|||||||
|
<h1>Sinatra + Sidekiq Example</h1>
|
||||||
|
<h2>Failed: <%= @failed %></h2>
|
||||||
|
<h2>Processed: <%= @processed %></h2>
|
||||||
|
|
||||||
|
<form method="post" action="/msg">
|
||||||
|
<input type="text" name="msg">
|
||||||
|
<input type="submit" value="Add Message">
|
||||||
|
</form>
|
||||||
|
|
||||||
|
<a href="/">Refresh page</a>
|
||||||
|
|
||||||
|
<h3>Messages</h3>
|
||||||
|
<% @messages.each do |msg| %>
|
||||||
|
<p><%= msg %></p>
|
||||||
|
<% end %>
|
@ -0,0 +1,15 @@
|
|||||||
|
require 'sinatra'
|
||||||
|
require 'sidekiq'
|
||||||
|
require 'redis'
|
||||||
|
require 'sidekiq/api'
|
||||||
|
|
||||||
|
$redis = Redis.new
|
||||||
|
|
||||||
|
class SinatraWorker
|
||||||
|
include Sidekiq::Worker
|
||||||
|
|
||||||
|
def perform(msg="lulz you forgot a msg!")
|
||||||
|
sleep 2 + rand(10)
|
||||||
|
$redis.lpush("sinkiq-example-messages", msg)
|
||||||
|
end
|
||||||
|
end
|
Loading…
Reference in New Issue