# Check processing queue for any previously unprocessed items.
# If previously unprocessed item
# Check if item key is not expired and push back to processing queue
# Otherwise push back onto work queue
# (May want to r_push if we need immediate processing)
lua_script = f"""
local saved_item = redis.call('rpop', 'processing_list')
if (saved_item ~= nil) then
if (redis.call('exists', 'processing_list' .. _ .. saved_item) == 1) then
redis.call('lpush', 'processing_list', saved_item)
else
redis.call('lpush', 'work_list', saved_item)
end
end
"""
self._queue_client.get_redis_client().eval(lua_script, 0)上面我尝试使用redis实现一个持久队列。我需要这部分逻辑是原子的，但由于redis事务不允许中间读写，我不得不求助于lua。问题是初始的“rpop”行不起作用。我在redis cli中验证了它返回（nil），因此“saved\u item”变量从未正确设置。有没有更好的方法来完成中间读取，然后使用该值执行条件逻辑？
1条答案
按热度按时间rt4zxlrg1#
作为lua的一个新手，我不得不在这个问题上下功夫，直到它成功为止，如果不梳理lua的文档，我仍然没有弄清楚原因。关键是创建一个局部函数，从中返回rpop项，并将其存储在局部变量中，而不是直接尝试。与lua返回值有关。