The job is executed method perform of the job class. If the tube is called 'park-fun'

  class ParkFun

  def self.perform (job)

  end

use send_response(result: object)

return report_error(message: 'i18n_message_key", args)

Use raise_error(message: 'i18n_message_key", args)

Use the db object.

The first argument is the query string followed by a variable number of arguments that are bound to the query.

   db.exec('SELECT fun FROM public.park where id=$1', id_value)

Returns an xxx

Use the redis accessor to obtain a Redis object already connected

Call send_mail

Use config

Use logger