首页 / PYTHON / Python 学习笔记 - Redis

Python 学习笔记 - Redis

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python 学习笔记 - Redis，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4746字，纯文字阅读大概需要7分钟。

内容图文

Redis 和Memcached类似也是一个开源的内存存储系统，存储格式也是通过键值对的方式。不过和memcached比起来，memcached的value只支持字符串，而redis支持字符串，列表，集合，hash等等；这些数据类型都支持push/pop，add/remove等操作，而且都是原子性的，也就是类似数据库的事物特征一样，所有的操作要么全部完成，要么全部失败，然后回滚到之前的状态。

现在来看看他的简单使用和发布订阅的功能。

服务器安装

[root@sydnagios ~]# wget http://download.redis.io/releases/redis-3.0.6.tar.gz 
[root@sydnagios ~]# tar xzf redis-3.0.6.tar.gz
[root@sydnagios ~]# cd redis-3.0.6/
[root@sydnagios redis-3.0.6]# make

装好的界面如下，使用默认的配置文件，他的访问端口是6379

make[1]: Leaving directory `/root/redis-3.0.6/src‘
[root@sydnagios redis-3.0.6]# src/redis-server
24344:C 07 Nov 10:40:21.763 # Warning: no config file specified, using the default confif
24344:M 07 Nov 10:40:21.764 * Increased maximum number of open files to 10032 (it was or.
                _._
           _.-``__ ‘‘-._
      _.-``    `.  `_.  ‘‘-._           Redis 3.0.6 (00000000/0) 64 bit
  .-`` .-```.  ```\/    _.,_ ‘‘-._
 (    ‘      ,       .-`  | `,    )     Running in standalone mode
 |`-._`-...-` __...-.``-._|‘` _.-‘|     Port: 6379
 |    `-._   `._    /     _.-‘    |     PID: 24344
  `-._    `-._  `-./  _.-‘    _.-‘
 |`-._`-._    `-.__.-‘    _.-‘_.-‘|
 |    `-._`-._        _.-‘_.-‘    |           http://redis.io
  `-._    `-._`-.__.-‘_.-‘    _.-‘
 |`-._`-._    `-.__.-‘    _.-‘_.-‘|
 |    `-._`-._        _.-‘_.-‘    |
  `-._    `-._`-.__.-‘_.-‘    _.-‘
      `-._    `-.__.-‘    _.-‘
          `-._        _.-‘
              `-.__.-‘
24344:M 07 Nov 10:40:21.766 # WARNING: The TCP backlog setting of 511 cannot be enforced.
24344:M 07 Nov 10:40:21.766 # Server started, Redis version 3.0.6
24344:M 07 Nov 10:40:21.766 # WARNING overcommit_memory is set to 0! Background save may.
24344:M 07 Nov 10:40:21.766 # WARNING you have Transparent Huge Pages (THP) support enab.
24344:M 07 Nov 10:40:21.766 * The server is now ready to accept connections on port 6379

然后别忘记打开防火墙端口

[root@sydnagios ~]# firewall-cmd --add-port=6379/tcp --permanent
success
[root@sydnagios ~]# systemctl restart firewalld

接下来用同一个目录下的客户端程序测试一下，成功设置和获取数据

[root@sydnagios redis-3.0.6]# src/redis-cli
127.0.0.1:6379> set foo bar
OK
127.0.0.1:6379> get foo
"bar"
127.0.0.1:6379>

现在看看Python下如何调用。

首先安装redis模块

C:\WINDOWS\system32>pip install redis
Collecting redis
  Using cached redis-2.10.5-py2.py3-none-any.whl
Installing collected packages: redis
Successfully installed redis-2.10.5

第一个例子：

import redis
r=redis.Redis(host=‘sydnagios‘,port=6379)
r.set(‘name‘,‘John‘)
print(r.get(‘name‘))
-------
b‘John‘

除了直接连接也可以通过连接池连接，默认每个redis实例有自己的连接池，通过这种方式，可以多个实例共享一个连接池

import redis
pool=redis.ConnectionPool(host=‘sydnagios‘,port=6379)
r=redis.Redis(connection_pool=pool)
print(r.get(‘name‘))

redis和memcached比起来，因为他支持多种数据结构，因此对应的操作函数也很多，几乎是memcached的10倍

下面是一些常见的，具体的函数使用可以参考 http://www.cnblogs.com/wupeiqi/articles/5132791.html

批量设置，批量获取

pool=redis.ConnectionPool(host=‘sydnagios‘,port=6379)
r=redis.Redis(connection_pool=pool)
r.mset(name=‘kevin‘,age=14)
print(r.mget(‘name‘,‘age‘))
-----------
[b‘kevin‘, b‘14‘]

自增

import redis
pool=redis.ConnectionPool(host=‘sydnagios‘,port=6379)
r=redis.Redis(connection_pool=pool)
r.incrby(‘age‘,10)
print(r.get(‘age‘))
-------
b‘24‘

删除

import  redis
r=redis.Redis(host=‘sydnagios‘,port=6379)
r.delete(‘set1‘)

Hash批量操作

import redis
pool=redis.ConnectionPool(host=‘sydnagios‘,port=6379)
r=redis.Redis(connection_pool=pool)
r.hmset(‘computer‘,{‘Macbook‘:20000,‘Surface3‘:5000,‘iPhone7‘:9000})
print(r.hmget(‘computer‘,‘Macbook‘))
--------
[b‘20000‘]

list操作

import  redis
r=redis.Redis(host=‘sydnagios‘,port=6379)
r.lpush(‘list1‘,‘apple‘)
r.lpush(‘list1‘,‘pear‘)
print(r.llen(‘list1‘))
print(r.lpop(‘list1‘))
print(r.llen(‘list1‘))
------
2
b‘pear‘
1

set操作，集合的元素不可以重复

import  redis
r=redis.Redis(host=‘sydnagios‘,port=6379)
r.sadd(‘set1‘,‘orange‘)
r.sadd(‘set1‘,‘mango‘)
print(r.scard(‘set1‘))
print(r.smembers(‘set1‘))
---------
2
{b‘mango‘, b‘orange‘}

管道

默认redis-py在执行一次操作请求的时候会自动连接，然后断开；我们可以通过管道，一次性传入多条操作然后执行。

# !/usr/bin/env python
# -*- coding:utf-8 -*-
import redis
pool = redis.ConnectionPool(host=‘sydnagios‘, port=6379)
r = redis.Redis(connection_pool=pool)
# pipe = r.pipeline(transaction=False)
pipe = r.pipeline(transaction=True)
r.set(‘name‘, ‘alex‘)
r.set(‘age‘, 16)
pipe.execute()

因为redis的函数实在太多这里就不一一赘述了。

现在来看一个redis的使用场景，发布和订阅。

简单的说，发布者可以对一个频道发布数据，然后凡是订阅了这个频道的人都可以收到信息。

s3.py

import redis
class RedisHelper:
    def __init__(self):
        self.__conn = redis.Redis(host=‘sydnagios‘)
    def publish(self, msg, chan):
        self.__conn.publish(chan, msg)
        return True
    def subscribe(self, chan):
        pub = self.__conn.pubsub()
        pub.subscribe(chan)
        pub.parse_response()
        return pub

s4.py(订阅者）

import s3
obj = s3.RedisHelper()
data = obj.subscribe(‘fm111.7‘)
print(data.parse_response())

s5.py（发布者）

import s3
obj = s3.RedisHelper()
obj.publish(‘alex db‘, ‘fm111.7‘)

先执行订阅者的代码，进入等待状态，然后执行发布者的程序，对指定的channel发送数据‘alex db’，订阅者一方会收到以下数据

[b‘message‘, b‘fm111.7‘, b‘alex db‘]

本文出自 “麻婆豆腐” 博客，请务必保留此出处http://beanxyz.blog.51cto.com/5570417/1870139

原文：http://beanxyz.blog.51cto.com/5570417/1870139

内容总结

以上是互联网集市为您收集整理的Python 学习笔记 - Redis全部内容，希望文章能够帮你解决Python 学习笔记 - Redis所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1260276.html

来源：【匿名】

【上一篇】[Machine Learning]Python机器学习库【下一篇】浅谈PHP运行Python脚本的方法

更多 ►

【Python 学习笔记 - Redis】教程文章相关的互联网学习教程文章

Python操作redispython连接方式：点击　　下面介绍详细使用1、String 操作　　redis中的String在在内存中按照一个name对应一个value来存储set()#在Redis中设置值，默认不存在则创建，存在则修改 r.set(‘name‘, ‘zhangsan‘) ‘‘‘参数：set(name, value, ex=None, px=None, nx=False, xx=False)ex，过期时间（秒）px，过期时间（毫秒）nx，如果设置为True，则只有name不存在时，当前set操作才执行,同setnx(name, value)xx，如果...

一 .linux上安装 python git redis nginx【代码】【图】

一 Linux平台上 python git redis nginx 源码包安装下载依赖库 yum -y install gcc gcc-c++ autoconf automake yum -y install zlib zlib-devel openssl openssl-devel pcre pcre-devel yum -y install gcc automake autoconf libtool make1. Python安装图解https://www.cnblogs.com/Jimc/p/10218387.htmltar -zxvf Python-3.6.5.tgz ...

python-redis连接管理【代码】【图】

Redis 数据类型 Redis支持五种数据类型：string（字符串）hash（哈希）list（列表）set（集合）zset(sorted set：有序集合)string:key:namevalue:runoob128.127.0.0.1:6379> SET name "runoob"OK127.0.0.1:6379> GET name"runoob"127.0.0.1:6379> TYPE namestringhash(就是字典类型)127.0.0.1:6379> HMSET myhash field1 "Hello" field2 "World"OK127.0.0.1:6379> HGET myhash field1"Hello"127.0.0.1:6379> HGET myhash field2"Wo...

redis之pythonApi操作【代码】【图】

01 redis入门1 redis介绍1.1 什么是redis?redis是一款键值型内存数据库软件，它没有表默认有0-15号仓库是存储数据的软件，跟语言无关，纯内存数据库（所有数据都放在内存中）速度非常快，支持的数据类型多样（5 大数据类型：字符串，列表，字典，集合，有序集合）1.2Memcached和redis比较? redis是单线程，单进程，数据类型丰富（只针对于 redis 6.0以下） ? memcache多线程多进程，数据类型单一，1.2redis为什么单线程，单进程...

基于Python项目的Redis缓存消耗内存数据简单分析（附详细操作步骤）

https://www.cnblogs.com/liuzhen1995/p/9265383.htmlRedis：一个高性能的key-value数据库。支持数据的持久化，可以将内存中的数据保存在磁盘中，重启的时候可以再次加载进行使用；提供string、list、set、zset、hash等数据结构的存储，并支持数据的备份。本文适合使用的场景：当一个项目中Redis缓存的数据量逐渐增大，Redis缓存的数据占用内存也会越来越大，而且其中有很多很可能是价值不大的数据。由于Redis是一个key-value数据...

redis学习一（key）键，Python操作redis 键【代码】

# -*- coding: utf-8 -*-import redis #这个redis 连接不能用，请根据自己的需要修改 r =redis.Redis(host="123.516.174.910",port=6379,password="11111608")1. delete DEL 命令用于删除已存在的键。不存在的 key 会被忽略print r.set(‘1‘, ‘4028b2883d3f5a8b013d57228d760a93‘) #set 设置指定 key 的值，如果设置正确返回 Trueprint r.get(‘1‘) # 得到键为1 的值 4028b2883d3f5a8b013d57228d760a93print r.delete(‘1...

Python如何操作redis

做UI自动化时，遇到一个问题，需要在后台操作完成后，产生结果才能在前端进行操作，但是用自动化在后台操作又很麻烦，就想直接操作数据库，然后再在前端进行操作；这时遇到一个问题，在后台操作时，会写入到数据库和缓存中，然后前端从缓存中取数据，如果缓存中没有数据的话，再从数据库中进行获取。但是如果直接操作数据库的话，就不会写入到缓存中，如果缓存中这时有数据的话，在数据库修改完成后，对前端就不会生效。那么就想到...

python 添加tab支持及安装redis

添加tab支持tab内容：vim tab.py#! /usr/bin/pythonimport sysimport readlineimport rlcompleterimport osreadline.parse_and_bind(‘tab: complete‘)histfile = os.path.join(os.environ[‘HOME‘],‘.pythonhistory‘)2.查看python遍历路径>>> import sys>>> sys.path[‘‘, ‘/usr/local/pyhon2.7/lib/python2.7/site-packages/setuptools-18.4-py2.7.egg‘, ‘/usr/local/pyhon2.7/lib/python2.7/site-packages/readline-6.2...

Python-Redis系列之--集合(set)【代码】

无序集合1.在name对应的集合中添加元素,可以添加多个元素sadd(name,values) redis_conn.sadd(‘name‘, ‘王二狗‘, ‘王大锤‘) # 向集合中添加元素 result = redis_conn.smembers(‘name‘) # 获取当前set集合中的元素内容2.获取name对应的集合的所有成员smembers(name)result = redis_conn.smembers(‘name‘) # 获取当前set集合中的元素内容3.srem(name, values)：在name对应的集合中删除某些值，可以删除多个值 resul...

一个简单的监控redis性能的python脚本【代码】

一个简单的监控redis性能的python脚本上一篇已经讲了如何监控memcached了，现在也顺带讲如何监控redis。首先介绍下监控redis那些信息：Redis ping：检验pingRedis alive：查看检查端口是否aliveRedis connections：查看连接数Redis blockedClients：正在等待阻塞客户端数量Redis connectionsUsage：redis的连接使用率Redis memoryUsage：redis内存使用量Redis memoryUsageRate：redis内存使用率Redis evictedKeys：运行以来删除过...

python操作Redis缓存【代码】【图】

一、Redis的安装xshell连上服务器，依次输入以下代码：wget http://download.redis.io/releases/redis-3.0.6.tar.gz tar xzf redis-3.0.6.tar.gz cd redis-3.0.6 make 　　如果不巧发生以下截图中的错误：　　说明未安装gcc，如果是centos系统，输入：yum install gcc安装gcc即可，然后再次输入make执行。　　输入make后，很不幸，再次发生如下截图错误：　　推测是因为编译库的问题。　　将make改为make MALLOC=libc 再次运行！好...

python 结合redis 队列做一个例子【代码】

结合redis 队列做了一个例子#!/usr/bin/env python # coding: utf-8 # @Time : 2018/12/21 0021 13:57 # @Site : # @File : demos.py # @Software: PyCharm import MySQLdb import redis import json import os, time import threading from multiprocessing import Pool, Process import os, time, random import sysreload(sys) sys.setdefaultencoding(‘utf8‘)class InsertData():def __init__(self):# 去掉一些无...

使用python操作RabbitMQ,Redis,Memcache,SQLAlchemy 其一

一.概念1.Memcached Memcached 是一个高性能的分布式内存对象缓存系统，用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数，从而提高动态、数据库驱动网站的速度。Memcached基于一个存储键/值对的hashmap。其守护进程（daemon ）是用C写的，但是客户端可以用任何语言来编写，并通过memcached协议与守护进程通信。2.RabbitMQ RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他...

python爬虫12--文件存储之非关系型数据库存储Redis【代码】

1.Redis连接启动服务：cd redis的安装路径------>redis-server.execd redis的安装路径------>redis-clipython中连接redis：#第一种连接from redis import StrictRedis redis = StrictRedis(host=‘localhost‘,port=6379,db=0) #第二种连接from redis import StrictRedis,ConnectionPool pool = ConnectionPool(host=‘localhost‘,port=6379,db=0) redis = StrictRedis(connection_pool=pool) redis.set(‘name‘,‘bob‘) print(...