8
Próbuję uzyskać active_job pracy z delayed_job. Wszystko działa poprawnie ... jak w kodzie jest wykonywane zgodnie z oczekiwaniami, ale zgłoszenie delayed_job zgłasza, że wystąpił błąd. Błąd, który otrzymuję, jest poniżej.Aktywności aktywne powodujące nieoczekiwany błąd
uninitialized constant ProcessEventJob
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/inflector/methods.rb:261:in `const_get'
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/inflector/methods.rb:261:in `block in constantize'
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/inflector/methods.rb:259:in `each'
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/inflector/methods.rb:259:in `inject'
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/inflector/methods.rb:259:in `constantize'
/home/getsmart/.rvm/gems/[email protected]/gems/activesupport-4.2.1/lib/active_support/core_ext/string/inflections.rb:66:in `constantize'
/home/getsmart/.rvm/gems/[email protected]/gems/activejob-4.2.1/lib/active_job/core.rb:25:in `deserialize'
/home/getsmart/.rvm/gems/[email protected]/gems/activejob-4.2.1/lib/active_job/execution.rb:20:in `execute'
/home/getsmart/.rvm/gems/[email protected]/gems/activejob-4.2.1/lib/active_job/queue_adapters/delayed_job_adapter.rb:34:in `perform'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/backend/base.rb:94:in `block in invoke_job'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `block in initialize'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `execute'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:40:in `run_callbacks'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/backend/base.rb:91:in `invoke_job'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:204:in `block (2 levels) in run'
/home/getsmart/.rvm/rubies/ruby-2.2.2/lib/ruby/2.2.0/timeout.rb:89:in `block in timeout'
/home/getsmart/.rvm/rubies/ruby-2.2.2/lib/ruby/2.2.0/timeout.rb:99:in `call'
/home/getsmart/.rvm/rubies/ruby-2.2.2/lib/ruby/2.2.0/timeout.rb:99:in `timeout'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:204:in `block in run'
/home/getsmart/.rvm/rubies/ruby-2.2.2/lib/ruby/2.2.0/benchmark.rb:303:in `realtime'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:203:in `run'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:280:in `block in reserve_and_run_one_job'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `block in initialize'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `execute'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:40:in `run_callbacks'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:280:in `reserve_and_run_one_job'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:187:in `block in work_off'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:186:in `times'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:186:in `work_off'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:150:in `block (4 levels) in start'
/home/getsmart/.rvm/rubies/ruby-2.2.2/lib/ruby/2.2.0/benchmark.rb:303:in `realtime'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:149:in `block (3 levels) in start'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `block in initialize'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `execute'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:40:in `run_callbacks'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:148:in `block (2 levels) in start'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:147:in `loop'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:147:in `block in start'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/plugins/clear_locks.rb:7:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/plugins/clear_locks.rb:7:in `block (2 levels) in <class:ClearLocks>'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:79:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:79:in `block (2 levels) in add'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:61:in `block in initialize'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:79:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:79:in `block in add'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:66:in `execute'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/lifecycle.rb:40:in `run_callbacks'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/worker.rb:146:in `start'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:124:in `run'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:112:in `block in run_process'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/application.rb:265:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/application.rb:265:in `block in start_proc'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/daemonize.rb:84:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/daemonize.rb:84:in `call_as_daemon'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/application.rb:269:in `start_proc'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/application.rb:295:in `start'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/controller.rb:56:in `run'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons.rb:193:in `block in run_proc'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/cmdline.rb:88:in `call'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons/cmdline.rb:88:in `catch_exceptions'
/home/getsmart/.rvm/gems/[email protected]/gems/daemons-1.2.2/lib/daemons.rb:192:in `run_proc'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:110:in `run_process'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:91:in `block in daemonize'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:89:in `times'
/home/getsmart/.rvm/gems/[email protected]/gems/delayed_job-4.0.6/lib/delayed/command.rb:89:in `daemonize' bin/delayed_job:5:in `<main>'
ProcessEventJob jest moja klasa praca, która siedzi w app/jobs/process_event_job.rb.
class ProcessEventJob < ActiveJob::Base
queue_as :event_handler_cycle
def perform(event)
Events::EventHandler.new(raw_data: event).call
end
end
Wołam go
ProcessEventJob.perform_later(params)
I ponownym uruchomieniu serwera i delayed_jobs. Zapewnienie, że działa pod prawidłowymi zmiennymi środowiskowymi. Nie bardzo wiem, co jeszcze można zrobić. Mogę również uzyskać dostęp do grzywny ProcessEventJob z konsoli.
Myślałem, że pliki w folderze aplikacji będą automatycznie wymagane.
Wszelkie przemyślenia na temat debugowania tego będą mile widziane.
EDIT
Uwaga poniższy kod wywołuje opóźnioną pracę. Jest to eksponowany punkt końcowy, którego używamy do rejestrowania zdarzeń.
module Api
module V1
class SegmentEventsController < ApiController
def create
begin
ProcessEventJob.perform_later(params)
render_success
rescue StandardError => e
render_fail
end
end
private
def render_success
render status: 200, json: { "success" => "true" }
end
def render_fail
render status: 400, json: { "success" => "false" }
end
def restrict_access
unless ApiKey.exists?(access_token: params[:access_token])
head :unauthorized
end
end
end
end
end
Rails.application.configure do
# Settings specified here will take precedence over those in config/application.rb.
# Code is not reloaded between requests.
config.cache_classes = true
# Eager load code on boot. This eager loads most of Rails and
# your application in memory, allowing both threaded web servers
# and those relying on copy on write to perform better.
# Rake tasks automatically ignore this option for performance.
config.eager_load = true
# Full error reports are disabled and caching is turned on.
config.consider_all_requests_local = false
config.action_controller.perform_caching = true
# Enable Rack::Cache to put a simple HTTP cache in front of your application
# Add `rack-cache` to your Gemfile before enabling this.
# For large-scale production use, consider using a caching reverse proxy like nginx, varnish or squid.
# config.action_dispatch.rack_cache = true
# Disable Rails's static file server (Apache or nginx will already do this).
config.serve_static_files = false
# Compress JavaScripts and CSS.
config.assets.js_compressor = :uglifier
config.assets.css_compressor = :sass
# Do not fallback to assets pipeline if a precompiled asset is missed.
config.assets.compile = false
# Generate digests for assets URLs.
config.assets.digest = true
# `config.assets.precompile` has moved to config/initializers/assets.rb
# Specifies the header that your server uses for sending files.
# config.action_dispatch.x_sendfile_header = "X-Sendfile" # for apache
# config.action_dispatch.x_sendfile_header = 'X-Accel-Redirect' # for nginx
# Force all access to the app over SSL, use Strict-Transport-Security, and use secure cookies.
# config.force_ssl = true
# Set to :debug to see everything in the log.
config.log_level = :info
# Prepend all log lines with the following tags.
# config.log_tags = [ :subdomain, :uuid ]
# Use a different logger for distributed setups.
# config.logger = ActiveSupport::TaggedLogging.new(SyslogLogger.new)
# Use a different cache store in production.
# config.cache_store = :mem_cache_store
# Enable serving of images, stylesheets, and JavaScripts from an asset server.
# config.action_controller.asset_host = "http://assets.example.com"
# Precompile additional assets.
# application.js, application.css, and all non-JS/CSS in app/assets folder are already added.
# config.assets.precompile += %w(search.js)
# Ignore bad email addresses and do not raise email delivery errors.
# Set this to true and configure the email server for immediate delivery to raise delivery errors.
config.action_mailer.raise_delivery_errors = false
config.action_mailer.default_url_options = { :host => 'mywebsite.co.za' }
config.action_mailer.perform_deliveries = true
config.action_mailer.delivery_method = :smtp
config.action_mailer.smtp_settings = {
:address => "smtp.gmail.com",
:port => 587,
:user_name => 'email',
:password => 'password',
:authentication => 'plain',
:enable_starttls_auto => true }
# Enable locale fallbacks for I18n (makes lookups for any locale fall back to
# the I18n.default_locale when a translation cannot be found).
config.i18n.fallbacks = true
# Send deprecation notices to registered listeners.
config.active_support.deprecation = :notify
# Disable automatic flushing of the log to improve performance.
# config.autoflush_log = false
# Use default logging formatter so that PID and timestamp are not suppressed.
config.log_formatter = ::Logger::Formatter.new
# Do not dump schema after migrations.
config.active_record.dump_schema_after_migration = false
config.active_job.queue_adapter = :delayed_job
end
EDIT
Tak więc wydaje się, że pewien postęp, ale nadal nie ma sensu. Moja konfiguracja na etapie przemieszczania ma wiele uruchomionych aplikacji. Dwa z nich używają delayed_jobs.
Pomyślałem, że może zaistnieją pewne konflikty między tymi dwoma, więc zatrzymałem opóźnione_odbywanie, których nie potrzebowałem i nagle wszystko zaczęło działać poprawnie. Natknąłem się na post, który mówi, że możesz uruchomić dwa wystąpienia, jeśli użyjesz -i ...
Nie jestem do końca pewien, czy tego właśnie szukam.
gdzie ProcessEventJob wywoływana jest? –
patrz edytuj, skąd jest wywoływany. –
Czy to działa, jeśli ręcznie wymagasz 'process_event_job.rb', być może w inicjalizatorze? – zetetic