Python操作nosql数据库
2017-11-25 00:31
197 查看
1.NoSQL,泛指非关系型的数据库。
2.python操作redis
redis的概念:
redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash(哈希类型)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。
Redis 是一个高性能的key-value数据库。 redis的出现,很大程度补偿了memcached这类key/value存储的不足,在部 分场合可以对关系数据库起到很好的补充作用。它提供了Java,C/C++,C#,PHP,JavaScript,Perl,Object-C,Python,Ruby,Erlang等客户端,使用很方便
Redis支持主从同步。数据可以从主服务器向任意数量的从服务器上同步,从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。存盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制,使得从数据库在任何地方同步树时,可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。
Redis的安装
>>cd /usr/local/src
>>wget
http://download.redis.io/releases/redis-3.0.1.tar.gz
>>ar xzf redis-3.0.1.tar.gz
>>cd redis-3.0.1
>>make
>>src/redis-server &
检查redis是否正常启动
Ps –ef |grep redis
Netstat –lnp |grep 6379
安装redis的客户端
Pip install redis
3.连接池
redis-py使用connection pool来管理对一个redis server的所有连接,避免每次建立、释放连接的开销。默认,每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池,然后作为参数Redis,这样就可以实现多个Redis实例共享一个连接池
#! /usr/bin/env/python
# -*- coding: utf-8 -*-
# @Time : 2017/11/25 0:24
# @Author : zhoukai-fx
# @File : kkj.py
import redis
pool = redis.ConnectionPool(host="192.168.1.110")
r = redis.Redis(connection_pool=pool)
r.set("name", "yinduasan")
print(r.get("name"))返回结果:
yinduasan
4.管道
redis-py默认在执行每次请求都会创建(连接池申请连接)和断开(归还连接池)一次连接操作,如果想要在一次请求中指定多个命令,则可以使用pipline实现一次请求指定多个命令,并且默认情况下一次pipline 是原子性操作。减少功耗
redis是一个cs模式的tcp server,使用和http类似的请求响应协议。一个client可以通过一个socket连接发起多个请求命令。每个请求命令发出后client通常会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client。
withpipe time is : 28000
withoutpipe time is : 253000#管道比普通的插入速度要快
2.python操作redis
redis的概念:
redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash(哈希类型)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。
Redis 是一个高性能的key-value数据库。 redis的出现,很大程度补偿了memcached这类key/value存储的不足,在部 分场合可以对关系数据库起到很好的补充作用。它提供了Java,C/C++,C#,PHP,JavaScript,Perl,Object-C,Python,Ruby,Erlang等客户端,使用很方便
Redis支持主从同步。数据可以从主服务器向任意数量的从服务器上同步,从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。存盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制,使得从数据库在任何地方同步树时,可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。
Redis的安装
>>cd /usr/local/src
>>wget
http://download.redis.io/releases/redis-3.0.1.tar.gz
>>ar xzf redis-3.0.1.tar.gz
>>cd redis-3.0.1
>>make
>>src/redis-server &
检查redis是否正常启动
Ps –ef |grep redis
Netstat –lnp |grep 6379
安装redis的客户端
Pip install redis
3.连接池
redis-py使用connection pool来管理对一个redis server的所有连接,避免每次建立、释放连接的开销。默认,每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池,然后作为参数Redis,这样就可以实现多个Redis实例共享一个连接池
#! /usr/bin/env/python
# -*- coding: utf-8 -*-
# @Time : 2017/11/25 0:24
# @Author : zhoukai-fx
# @File : kkj.py
import redis
pool = redis.ConnectionPool(host="192.168.1.110")
r = redis.Redis(connection_pool=pool)
r.set("name", "yinduasan")
print(r.get("name"))返回结果:
yinduasan
4.管道
redis-py默认在执行每次请求都会创建(连接池申请连接)和断开(归还连接池)一次连接操作,如果想要在一次请求中指定多个命令,则可以使用pipline实现一次请求指定多个命令,并且默认情况下一次pipline 是原子性操作。减少功耗
redis是一个cs模式的tcp server,使用和http类似的请求响应协议。一个client可以通过一个socket连接发起多个请求命令。每个请求命令发出后client通常会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client。
import datetime import redis def withpipe(r): pipe = r.pipeline(transaction=True) for i in xrange(1, 1000): key = "test1" +str(i) value = "test1" + str(i) pipe.set(key, value) pipe.execute() def withoutpipe(r): # pipe = r.pipeline(transaction=True) for i in xrange(1, 1000): key = "test1" + str(i) value = "test1" + str(i) r.set(key, value) if __name__ == "__main__": pool = redis.ConnectionPool(host="192.168.1.110", port=6379, db=0) r1 = redis.Redis(connection_pool=pool) r2 = redis.Redis(connection_pool=pool) start = datetime.datetime.now() # print(start) withpipe(r1) end = datetime.datetime.now() # print((end-start).microseconds) # print(end-start) t_time = (end - start).microseconds print("withpipe time is : {0}".format(t_time)) start = datetime.datetime.now() withoutpipe(r2) end = datetime.datetime.now() t_time = (end - start).microseconds print("withoutpipe time is : {0}".format(t_time))返回结果:
withpipe time is : 28000
withoutpipe time is : 253000#管道比普通的插入速度要快
相关文章推荐
- python操作nosql数据库之memcache
- nosql数据库-mongodb-入门(2)--用python的pymongo 操作mongodb
- Python操作nosql数据库之redis
- python模块系列 (二)之操作NoSQL数据库hbase
- python数据库操作常用功能使用详解(创建表/插入数据/获取数据)
- python操作数据库PostgreSQL
- 【python】数据库操作
- Django数据库操作(python)
- sqlalchemy 数据库多表操作(python语言)
- 第九篇:python高级之操作数据库
- Python 边做边学 9.4 数据库操作--排序条件单元(Qorder)
- Python 边做边学 9.9 数据库操作--数据库表配置(UserAreaCfg)
- 数据库在python中的操作(1)
- python-Django中设置操作shell时执行的数据库命令在控制台显示
- python操作数据库PostgreSQL
- NoSQL 数据库的主主备份及操作图解
- PyMySQL——python操作数据库
- python操作数据库
- python 操作mysql 数据库
- mongo数据库基本操作--python篇