让redis集成到django的库--django-redis

news/2024/6/20 17:28:46

安装

pip install django-redis

配置

作为 cache backend 使用配置

为了使用 django-redis , 你应该将你的 django cache setting 改成这样:

CACHES = {"default": {"BACKEND": "django_redis.cache.RedisCache","LOCATION": "redis://127.0.0.1:6379/1","OPTIONS": {"CLIENT_CLASS": "django_redis.client.DefaultClient",}}
}

为了更好的互操作性并使连接字符串更加 “标准”, 从 3.8.0 开始 django-redis 使用 redis-py native url notation 作为连接字符串.

URL 格式举例

redis://[:password]@localhost:6379/0
rediss://[:password]@localhost:6379/0
unix://[:password]@/path/to/socket.sock?db=0

支持三种 URL scheme :

  • redis://: 普通的 TCP 套接字连接
  • rediss://: SSL 包裹的 TCP 套接字连接
  • unix://: Unix 域套接字连接

指定数据库数字的方法:

  • db 查询参数, 例如: redis://localhost?db=0
  • 如果使用 redis:// scheme, 可以直接将数字写在路径中, 例如: redis://localhost/0

在某些环境下连接密码放在 url 是不安全的, 这时你可以忽略密码或者使用方便的 OPTIONS 设置:

CACHES = {"default": {"BACKEND": "django_redis.cache.RedisCache","LOCATION": "redis://127.0.0.1:6379/1","OPTIONS": {"CLIENT_CLASS": "django_redis.client.DefaultClient","PASSWORD": "mysecret"}}
}

注意, 如果你已经在 uri 中设置了密码,那么这样配置就不会覆盖 uri 中的密码, 此设置将被忽略.

套接字超时

套接字超时设置使用 SOCKET_TIMEOUT 和 SOCKET_CONNECT_TIMEOUT 参数:

CACHES = {"default": {# ..."OPTIONS": {"SOCKET_CONNECT_TIMEOUT": 5,  # in seconds"SOCKET_TIMEOUT": 5,  # in seconds}}
}

SOCKET_CONNECT_TIMEOUT : socket 建立连接超时设置

SOCKET_TIMEOUT : 连接建立后的读写操作超时设置

压缩支持

django-redis 支持压缩, 但默认是关闭的. 你可以激活它:

CACHES = {"default": {# ..."OPTIONS": {"COMPRESSOR": "django_redis.compressors.zlib.ZlibCompressor",}}
}

使用 lzma 压缩的例子:

import lzmaCACHES = {"default": {# ..."OPTIONS": {"COMPRESSOR": "django_redis.compressors.lzma.LzmaCompressor",}}
}

memcached 异常行为

在某些情况下, redis 只作为缓存使用, 当它关闭时如果你不希望触发异常. 这是 memcached backend 的默认行为, 你可以使用 django-redis 模拟这种情况.

为了设置这种类似memcached 的行为 ( 忽略连接异常 ), 使用 IGNORE_EXCEPTIONS 参数:

CACHES = {"default": {# ..."OPTIONS": {"IGNORE_EXCEPTIONS": True,}}
}

当然,你也可以给所有缓存配置相同的忽略行为:

DJANGO_REDIS_IGNORE_EXCEPTIONS = True

连接池

django-redis 使用 redis-py 的连接池接口, 并提供了简单的配置方式. 除此之外, 你可以为 backend 定制化连接池的产生.

redis-py 默认不会关闭连接, 尽可能重用连接

配置默认连接池

配置默认连接池很简单, 你只需要在 CACHES 中使用 CONNECTION_POOL_KWARGS 设置连接池的最大连接数量即可:

CACHES = {"default": {"BACKEND": "django_redis.cache.RedisCache",..."OPTIONS": {"CONNECTION_POOL_KWARGS": {"max_connections": 100}}}
}

你可以得知连接池已经打开多少连接:

from django.core.cache import get_cache
from django_redis import get_redis_connectionr = get_redis_connection("default")  # Use the name you have defined for Redis in settings.CACHES
connection_pool = r.connection_pool
print("Created connections so far: %d" % connection_pool._created_connections)

使用你自己的连接池子类

如果需要使用自己的连接池子类.

django-redis 提供了 CONNECTION_POOL_CLASS 来配置连接池子类

myproj/mypool.py

from redis.connection import ConnectionPoolclass MyOwnPool(ConnectionPool):# Just doing nothing, only for example purposepass

setting.py

# Omitting all backend declaration boilerplate code."OPTIONS": {"CONNECTION_POOL_CLASS": "myproj.mypool.MyOwnPool",
}

集群配置

CACHES = {"default": {"BACKEND": "django_redis.cache.RedisCache","LOCATION": ["redis://127.0.0.1:7000/0","redis://127.0.0.1:7001/0","redis://127.0.0.1:7002/0",],"OPTIONS": {"CLIENT_CLASS": "django_redis.client.DefaultClient","REDIS_CLIENT_KWARGS": {"decode_responses": True},},}
}

分片配置

CACHES = {"default": {"BACKEND": "django_redis.cache.RedisCache","LOCATION": ["redis://127.0.0.1:6379/1","redis://127.0.0.1:6379/2",],"OPTIONS": {"CLIENT_CLASS": "django_redis.client.ShardClient","REDIS_CLIENT_KWARGS": {"decode_responses": True},}}
}

操作

永不超时设置

django-redis 支持永不超时设置. 其表现和 django backend 指定的相同:

  • timeout=0 立即过期
  • timeout=None 永不超时
from django.core.cache import cachecache.set("key", "value", timeout=None)

通过值 (value) 获取 ttl (time to live)

在 redis 中, 你可以获取任何 key 的 ttl, django-redis 也支持获取 ttl 的函数:

它返回:

  • 0 key 不存在 (或已过期).
  • None key 存在但没有设置过期.
  • ttl 任何有超时设置的 key 的超时值.

例如

>>> from django.core.cache import cache
>>> cache.set("foo", "value", timeout=25)
>>> cache.ttl("foo")
25
>>> cache.ttl("not-existent")
0

expire & persist

除了简单的 ttl 查询, 你可以使用 persist 或者 expire 方法让一个值永久存在或者指定一个新的过期时间:

使用 persist 的例子:

>>> cache.set("foo", "bar", timeout=22)
>>> cache.ttl("foo")
22
>>> cache.persist("foo")
>>> cache.ttl("foo")
None

使用 expire 的例子:

>>> cache.set("foo", "bar", timeout=22)
>>> cache.expire("foo", timeout=5)
>>> cache.ttl("foo")
5

locks

django-redis 支持 redis 分布式锁. 锁的线程接口是相同的, 因此你可以使用它作为替代.

使用 python 上下文管理器分配锁的例子:

with cache.lock("somekey"):do_some_thing()

扫描 & 删除键 (keys)

django-redis 支持使用全局通配符的方式来检索或者删除键.

使用通配符搜索

>>> from django.core.cache import cache
>>> cache.keys("foo_*")
["foo_1", "foo_2"]

这个简单的写法将返回所有匹配的值, 但在拥有很大数据量的数据库中这样做并不合适.

在 redis 的 server side cursors 2.8 版及以上, 你可以使用 iter_keys 取代 keys 方法, iter_keys 将返回匹配值的迭代器, 你可以使用迭代器高效的进行遍历.

使用 游标 搜索

>>> from django.core.cache import cache
>>> cache.iter_keys("foo_*")
<generator object algo at 0x7ffa9c2713a8>
>>> next(cache.iter_keys("foo_*"))
"foo_1"

使用 delete_pattern

如果要删除键, 使用 delete_pattern 方法, 它和 keys 方法一样也支持全局通配符, 此函数将会返回删掉的键的数量

>>> from django.core.cache import cache
>>> cache.delete_pattern("foo_*")

Redis 本地命令

django-redis 有限制的支持一些 Redis 原子操作, 例如 SETNX 和 INCR 命令.

你可以在 set() 方法中加上 nx 参数使用来使用 SETNX 命令

>>> from django.core.cache import cache
>>> cache.set("key", "value1", nx=True)
True
>>> cache.set("key", "value2", nx=True)
False
>>> cache.get("key")
"value1"

当值 (value) 有合适的键 (key) 时, incr 和 decr 也可以使用 Redis 原子操作

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hjln.cn/news/34200.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈,一经查实,立即删除!

相关文章

我喜欢二次元

我喜欢二次元,因为我喜欢那个世界Tips:当你看到这个提示的时候,说明当前的文章是由原emlog博客系统搬迁至此的,文章发布时间已过于久远,编排和内容不一定完整,还请谅解` 我喜欢二次元 日期:2019-5-20 阿珏 二次元 浏览:7250次 评论:15条我喜欢二次元,是因为我喜欢那…

Linux中查看yum安装的jdk位置

Linux中查看yum安装的jdk位置 第一步 which指令会在环境变量$PATH设置的目录里查找符合条件的文件。 which java第二步 获取对应的环境名文件 /etc/alternatives/java [root@192 local]# ls -lr /usr/bin/java第三步 ls -lrt /etc/alternatives/java# t:将按照修改时间排序,最…

生活为什么总是对我动手?

睡衣出门取外卖,不想遇见熟人,偏偏被好多熟人看见;看电影时昏昏欲睡,中途上个厕所,就错过高光片段;在景区排队买票,Tips:当你看到这个提示的时候,说明当前的文章是由原emlog博客系统搬迁至此的,文章发布时间已过于久远,编排和内容不一定完整,还请谅解` 生活为什么总…

推进 OKR 目标管理落地的最佳实践

企业如何通过 Tita 推进 OKR 目标管理落地?本文将从 OKR 推进落地的四大阶段,来分别为大家介绍企业推进的全流程。这四个阶段分别是:OKR 实施准备阶段 OKR 制定阶段 OKR 执行推阶段 OKR 复盘阶段准备:OKR 实施准备阶段 OKR 实施准备阶段是开始部署和准备落地 OKR 的关键阶段…

如何优雅的提交一个表单

这是一个非常基础的HTML表单提交问题,但却是一个非常实用的技巧 我的业务场景是这样的:一个可动态创建input的表单,如下图Tips:当你看到这个提示的时候,说明当前的文章是由原emlog博客系统搬迁至此的,文章发布时间已过于久远,编排和内容不一定完整,还请谅解` 如何优雅的…

一些常见功能的查询sql

1、场景:查询一个选手的排名及距离上一名差多少票 方法二(去重排序查询比自己少的数量)Tips:当你看到这个提示的时候,说明当前的文章是由原emlog博客系统搬迁至此的,文章发布时间已过于久远,编排和内容不一定完整,还请谅解` 一些常见功能的查询sql 日期:2019-4-10 阿…

微信授权登录

微信的授权登录和QQ、新浪等平台的授权登录都大同小异,均采用 Oauth OAuth2.0鉴权方式。Tips:当你看到这个提示的时候,说明当前的文章是由原emlog博客系统搬迁至此的,文章发布时间已过于久远,编排和内容不一定完整,还请谅解` 微信授权登录 日期:2019-4-5 阿珏 折腾代码…

国产邪神手办开箱

“邪神”正是用于描述这些表情崩坏到离谱,细节不堪到令人发指的手办。 说起“邪神”,大家也许第一感觉就是“邪神四姐妹”,其实都是让人膜拜的存在,四大邪神的威名万世传扬,不仅可以辟邪,而且摆出来非常长脸有没有,杀人不见血的强大武器Tips:当你看到这个提示的时候,说…