Python Redis如何执行Lua脚本

 更新时间:2024年02月09日 08:38:07   作者:XerCis CSDN认证博客专家  
这篇文章主要介绍了Python Redis如何执行Lua脚本问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

问题描述

Python Redis 执行 Lua 脚本可实现原子性

官方文档表示,Redis 使用相同的 Lua 解释器来运行所有命令,Redis 保证脚本以原子方式执行:

  • 在执行脚本时不会执行其他脚本或 Redis 命令。
  • 这种语义类似于 MULTI / EXEC 的语义,从所有其他客户的角度来看,脚本的效果要么仍然不可见,要么已经完成。

解决方案

安装

pip install redis

代码

from redis import Redis

redis = Redis()
script = """
redis.call('SETEX', 'key', 100, 'value')
"""
redis.register_script(script)()  # 执行脚本

效果

传递参数

Script 类调用函数原型:

def __call__(self, keys=[], args=[], client=None)
from redis import Redis

redis = Redis()
script = """
local key = KEYS[1]
local seconds = ARGV[1]
local value = ARGV[2]
redis.call('SETEX', key, seconds, value)
"""
cmd = redis.register_script(script)
cmd(keys=['key'], args=[100, 'value'])  # 执行脚本

效果同上

分布式锁

1.加锁并设过期时间 SET lock_resource_name $uuid NX PX $expire_time,同时启动守护线程为快要过期单还没执行完毕的客户端的锁续命;

2.客户端执行业务逻辑操作共享资源;

3.通过 Lua 脚本释放锁,先 get 判断锁是否是自己加的,再执行 DEL

判断+删除

import time
from uuid import uuid4

from redis import Redis

redis = Redis()

# 判断是否自己创建的锁,是的话则释放
script = """
if redis.call('GET', KEYS[1]) == ARGV[1] then
    return redis.call('DEL', KEYS[1])
else
    return 0
end
"""


def do_something():
    name = 'lock'  # 锁名,此处故意写死让别的进程进来占用
    uuid = str(uuid4())
    # 上锁
    if redis.set(name=name, value=uuid, nx=True, ex=25):  # 锁不存在才能上锁成功,过期时间应为业务时间的五倍,此处故意写小,模拟过期释放
        print('上锁')
        try:
            print('处理业务', uuid)
            time.sleep(10)
        except Exception as e:
            print(e)
        finally:
            # 释放锁
            cmd = redis.register_script(script)
            res = cmd(keys=[name], args=[uuid])  # 执行脚本
            if res:
                print('锁已释放')
            else:
                print('不是自己的锁')
    else:
        print('锁已存在')


if __name__ == '__main__':
    do_something()

模拟过程:

  • 运行程序1
  • 手动迅速删掉这个锁
  • 运行程序2

效果:

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。 

相关文章

  • Redis报错:无法连接Redis服务的解决方法

    Redis报错:无法连接Redis服务的解决方法

    在Linux系统上运行Redis服务时,有时会遇到“无法连接Redis服务”的报错,本文就详细的介绍一下解决方法,具有一定的参考价值,感兴趣的可以了解一下
    2023-09-09
  • Redis源码阅读:Redis字符串SDS详解

    Redis源码阅读:Redis字符串SDS详解

    这篇文章主要介绍了Redis源码阅读:Redis字符串SDS,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-07-07
  • Redis sort 排序命令详解

    Redis sort 排序命令详解

    这篇文章主要介绍了Redis sort 排序命令详解,本文讲解了默认排序命令、排序方式命令、BY语法、GET用法示例等内容,需要的朋友可以参考下
    2015-07-07
  • redis如何取hash的值

    redis如何取hash的值

    这篇文章主要介绍了redis如何取hash的值问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-01-01
  • 完美解决linux上启动redis后配置文件未生效的问题

    完美解决linux上启动redis后配置文件未生效的问题

    今天小编就为大家分享一篇完美解决linux上启动redis后配置文件未生效的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • Redis基本数据类型哈希Hash常用操作命令

    Redis基本数据类型哈希Hash常用操作命令

    这篇文章主要为大家介绍了Redis基本数据类型哈希Hash常用操作,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-05-05
  • redis击穿 雪崩 穿透超详细解决方案梳理

    redis击穿 雪崩 穿透超详细解决方案梳理

    这篇文章主要为大家介绍了Redis击穿穿透雪崩产生原因及解决思路的解决方案参考,有需要的朋友可以借鉴参考下,希望能够有所帮助祝大家多多进步
    2022-03-03
  • Redis的LRU机制介绍

    Redis的LRU机制介绍

    这篇文章主要介绍了Redis的LRU机制介绍,Redis会按LRU算法删除设置了过期时间但还没有过期的key,而对于没有设置过期时间的key,Redis是永远保留的,需要的朋友可以参考下
    2015-06-06
  • 利用ganglia监控redis的最新解决方法

    利用ganglia监控redis的最新解决方法

    这篇文章主要给大家介绍了如何利用ganglia监控redis的最新解决方法,网上的资料基本上就是13年的一篇文章,但发现文章的内容有些许问题,于是整理了下最新的解决方法,下面通过这篇文章来一起详细的看看吧。
    2016-12-12
  • redis底层数据结构之skiplist实现示例

    redis底层数据结构之skiplist实现示例

    这篇文章主要为大家介绍了redis底层数据结构之skiplist实现示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12

最新评论