如何将包含pymongo db的函数传递到rq队列绕过无能力对_thread.lock进行序列化？

如何解决如何将包含pymongo db的函数传递到rq队列绕过无能力对_thread.lock进行序列化？

我有一个数据库和一个监视它的服务。我想将有关上述数据库的呼叫排队到rq.Queue：

callback.py

from pymongo import MongoClient


db_client = MongoClient(username='root',password='pass').db.collection


def do_something(db):
    while not list(db.find({})):
        print('empty db')
    print('found something')

但是，我每次尝试做这样的事情

from redis import Redis; from rq import Queue; from allocator import db_client,do_something
Queue(connection=Redis()).enqueue(do,(db_client,)

产生

TypeError: cannot pickle '_thread.lock' object

如何绕过此方法并允许排队的函数与数据库交互？

我尝试过的事情：

1. 使用另一个序列化器（莳萝-TypeError: cannot pickle 'sqlite3.Connection' object）
2. 在拥有数据库的类中包装do_something-同样的错误