Sidekiq: передать объект как параметр

Question

У меня есть работник sidekiq, который подключается к удаленной базе данных odbc, извлекает данные и затем обновляет локальную базу данных. Теперь я раскалываю рабочего на двух рабочих. Один будет подключаться и извлекать данные, а другой - обновлять записи.

Соединение возвращает объект #<OCI8::Cursor:0x00000007703f30>, что я передаю параметры второму работнику.

SecondWorker.perform_async({:odbc => connection}) 

Во второй работник я попытался использовать его:

def perform(options) 
    order_odbc = options['odbc'] 
end 

Но он рассматривает объект как строку

"#<OCI8::Cursor:0x00000006bddf48>":String 

Есть ли другой способ передать объекты в параметрах? (string, integer и т. Д.).

Answer 1

Sidekiq recommends, что аргументы для задания передаются как простые типы данных (string, integer и т. Д.).

Мой вопрос для вас - и я понимаю, что это не может быть вариантом в ваших деловых правилах и ограничениях - это «вам действительно нужен второй рабочий»?

Я могу рассмотреть вариант с обслуживанием или другим классом, выполняющим работу; вместо того, чтобы отталкивать другого работника.

# Inside First Worker 
SomeCoolClass.delay.method(params) 

С delay, этот метод будет обрабатывать асинхронно, и в моем опыте, я не имел проблемы со сложными объектами в таких случаях (в зависимости от вопросов, которые я имел, когда я проходил мимо сложные объекты/данные для работника) ,

Как я уже упоминал, может не работать для вашего приложения, но он хотел предложить предложение, поскольку он работал для меня в моих прецедентах.

Answer 2

Вы можете преобразовать свой объект в хэш. Это не лучший способ, но он работает.

Дополнительная информация here преобразовать объект в хэш.