oldboy第十三天学习

1、现在给我的感觉是，python终于入门了开始越学越简单了。变得更好理解了。

一、memcached

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

Python操作Memcached

1、第一次操作

 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)
 mc.set("foo", "bar")
 ret = mc.get('foo')
 print ret

Ps：debug = True 表示运行出现错误时，现实错误信息，上线后移除该参数。

2、天生支持集群

python-memcached模块原生支持集群操作，其原理是在内存维护一个主机列表，且集群中主机的权重值和主机在列表中重复出现的次数成正比

      主机    权重
     1.1.1.1   1
     1.1.1.2   2
     1.1.1.3   1

 那么在内存中主机列表为：
     host_list = ["1.1.1.1", "1.1.1.2", "1.1.1.2", "1.1.1.3", ]

如果用户根据如果要在内存中创建一个键值对（如：k1 = "v1"），那么要执行一下步骤：

• 根据算法将 k1 转换成一个数字
• 将数字和主机列表长度求余数，得到一个值 N（ 0 <= N < 列表长度 ）
• 在主机列表中根据 第2步得到的值为索引获取主机，例如：host_list[N]
• 连接 将第3步中获取的主机，将 k1 = "v1" 放置在该服务器的内存中

代码实现如下：

 mc = memcache.Client([('1.1.1.1:12000', 1), ('1.1.1.2:12000', 2), ('1.1.1.3:12000', 1)], debug=True)

 mc.set('k1', 'v1')

3、add
添加一条键值对，如果已经存在的 key，重复执行add操作异常

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)
 mc.add('k1', 'v1')
 # mc.add('k1', 'v2') # 报错，对已经存在的key重复添加，失败！！！

4、replace
replace 修改某个key的值，如果key不存在，则异常

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)
 # 如果memcache中存在kkkk，则替换成功，否则一场
 mc.replace('kkkk','')

5、set 和 set_multi

set            设置一个键值对，如果key不存在，则创建，如果key存在，则修改
set_multi   设置多个键值对，如果key不存在，则创建，如果key存在，则修改

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)

 mc.set('key0', 'wupeiqi')

 mc.set_multi({'key1': 'val1', 'key2': 'val2'})

6、delete 和 delete_multi

delete             在Memcached中删除指定的一个键值对
delete_multi    在Memcached中删除指定的多个键值对

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)

 mc.delete('key0')
 mc.delete_multi(['key1', 'key2'])

7、get 和 get_multi

get            获取一个键值对
get_multi   获取多一个键值对

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)

 val = mc.get('key0')
 item_dict = mc.get_multi(["key1", "key2", "key3"])

8、append 和 prepend

append    修改指定key的值，在该值 后面 追加内容
prepend   修改指定key的值，在该值 前面 插入内容

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)
 # k1 = "v1"

 mc.append('k1', 'after')
 # k1 = "v1after"

 mc.prepend('k1', 'before')
 # k1 = "beforev1after"

9、decr 和 incr　　

incr  自增，将Memcached中的某一个值增加 N （ N默认为1 ）
decr 自减，将Memcached中的某一个值减少 N （ N默认为1 ）

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache

 mc = memcache.Client(['10.211.55.4:12000'], debug=True)
 mc.set('k1', '')

 mc.incr('k1')
 # k1 = 778

 mc.incr('k1', 10)
 # k1 = 788

 mc.decr('k1')
 # k1 = 787

 mc.decr('k1', 10)
 # k1 = 777

10、gets 和 cas

如商城商品剩余个数，假设改值保存在memcache中，product_count = 900
A用户刷新页面从memcache中读取到product_count = 900
B用户刷新页面从memcache中读取到product_count = 900

如果A、B用户均购买商品

A用户修改商品剩余个数 product_count＝899
B用户修改商品剩余个数 product_count＝899

如此一来缓存内的数据便不在正确，两个用户购买商品后，商品剩余还是 899
如果使用python的set和get来操作以上过程，那么程序就会如上述所示情况！

如果想要避免此情况的发生，只要使用 gets 和 cas 即可，如：

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import memcache
 mc = memcache.Client(['10.211.55.4:12000'], debug=True, cache_cas=True)

 v = mc.gets('product_count')
 # ...
 # 如果有人在gets之后和cas之前修改了product_count，那么，下面的设置将会执行失败，剖出异常，从而避免非正常数据的产生
 mc.cas('product_count', "")

Ps：本质上每次执行gets时，会从memcache中获取一个自增的数字，通过cas去修改gets的值时，会携带之前获取的自增值和memcache中的自增值进行比较，如果相等，则可以提交，如果不想等，那表示在gets和cas执行之间，又有其他人执行了gets（获取了缓冲的指定值）， 如此一来有可能出现非正常数据，则不允许修改。

Memcached 真的过时了吗？

二、redis

redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

API使用

redis-py 的API的使用可以分类为：

• 连接方式
• 连接池
• 操作
  • String 操作
  • Hash 操作
  • List 操作
  • Set 操作
  • Sort Set 操作
• 管道
• 发布订阅

1.操作模式

redis-py提供两个类Redis和StrictRedis用于实现Redis的命令，StrictRedis用于实现大部分官方的命令，并使用官方的语法和命令，Redis是StrictRedis的子类，用于向后兼容旧版本的redis-py。

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-

 import redis

 r = redis.Redis(host='10.211.55.4', port=6379)
 r.set('foo', 'Bar')
 print r.get('foo')

2.连接池

redis-py使用connection pool来管理对一个redis server的所有连接，避免每次建立、释放连接的开销。默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数Redis，这样就可以实现多个Redis实例共享一个连接池。

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-

 import redis

 pool = redis.ConnectionPool(host='10.211.55.4', port=6379)

 r = redis.Redis(connection_pool=pool)
 r.set('foo', 'Bar')
 print r.get('foo')

3、操作

String操作，redis中的String在在内存中按照一个name对应一个value来存储。如图：

set(name, value, ex=None, px=None, nx=False, xx=False)

 在Redis中设置值，默认，不存在则创建，存在则修改
 参数：
      ex，过期时间（秒）
      px，过期时间（毫秒）
      nx，如果设置为True，则只有name不存在时，当前set操作才执行
      xx，如果设置为True，则只有name存在时，岗前set操作才执行

setnx(name, value)

# 设置值，只有name不存在时，执行设置操作（添加）

setex(name, value, time)

# 设置值 # 参数： # time，过期时间（数字秒 或 timedelta对象）

psetex(name, time_ms, value)

# 设置值 # 参数： # time_ms，过期时间（数字毫秒 或 timedelta对象）

mset(*args, **kwargs)

 批量设置值
 如：
     mset(k1='v1', k2='v2')
     或
     mget({'k1': 'v1', 'k2': 'v2'})

get(name)

获取值

mget(keys, *args)

 批量获取
 如：
     mget('ylr', 'wupeiqi')
     或
     r.mget(['ylr', 'wupeiqi'])

getset(name, value)

设置新值并获取原来的值

getrange(key, start, end)

 # 获取子序列（根据字节获取，非字符）
 # 参数：
     # name，Redis 的 name
     # start，起始位置（字节）
     # end，结束位置（字节）
 # 如： "武沛齐" ，0-3表示 "武"

setrange(name, offset, value)

 # 修改字符串内容，从指定字符串索引开始向后替换（新值太长时，则向后添加）
 # 参数：
     # offset，字符串的索引，字节（一个汉字三个字节）
     # value，要设置的值

setbit(name, offset, value)

 # 对name对应值的二进制表示的位进行操作

 # 参数：
     # name，redis的name
     # offset，位的索引（将值变换成二进制后再进行索引）
     # value，值只能是 1 或 0

 # 注：如果在Redis中有一个对应： n1 = "foo"，
         那么字符串foo的二进制表示为：01100110 01101111 01101111
     所以，如果执行 setbit('n1', 7, 1)，则就会将第7位设置为1，
         那么最终二进制则变成 01100111 01101111 01101111，即："goo"

 # 扩展，转换二进制表示：

     # source = "武沛齐"
     source = "foo"

     for i in source:
         num = ord(i)
         print bin(num).replace('b','')

     特别的，如果source是汉字 "武沛齐"怎么办？
     答：对于utf-8，每一个汉字占 3 个字节，那么 "武沛齐" 则有 9个字节
        对于汉字，for循环时候会按照 字节 迭代，那么在迭代时，将每一个字节转换 十进制数，然后再将十进制数转换成二进制
         11100110 10101101 10100110 11100110 10110010 10011011 11101001 10111101 10010000
         -------------------------- ----------------------------- -----------------------------
                     武                         沛                           齐

getbit(name, offset)

# 获取name对应的值的二进制表示中的某位的值 （0或1）

bitcount(key, start=None, end=None)

 # 获取name对应的值的二进制表示中 1 的个数
 # 参数：
     # key，Redis的name
     # start，位起始位置
     # end，位结束位置

bitop(operation, dest, *keys)

 # 获取多个值，并将值做位运算，将最后的结果保存至新的name对应的值

 # 参数：
     # operation,AND（并） 、 OR（或） 、 NOT（非） 、 XOR（异或）
     # dest, 新的Redis的name
     # *keys,要查找的Redis的name

 # 如：
     bitop("AND", 'new_name', 'n1', 'n2', 'n3')
     # 获取Redis中n1,n2,n3对应的值，然后讲所有的值做位运算（求并集），然后将结果保存 new_name 对应的值中

strlen(name)

# 返回name对应值的字节长度（一个汉字3个字节）

incr(self, name, amount=1)

 # 自增 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。

 # 参数：
     # name,Redis的name
     # amount,自增数（必须是整数）

 # 注：同incrby

incrbyfloat(self, name, amount=1.0)

 # 自增 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。

 # 参数：
     # name,Redis的name
     # amount,自增数（浮点型）

decr(self, name, amount=1)

 # 自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自减。

 # 参数：
     # name,Redis的name
     # amount,自减数（整数）

append(key, value)

 # 在redis name对应的值后面追加内容

 # 参数：
     key, redis的name
     value, 要追加的字符串

Hash操作，redis中Hash在内存中的存储格式如下图：

hset(name, key, value)

 # name对应的hash中设置一个键值对（不存在，则创建；否则，修改）

 # 参数：
     # name，redis的name
     # key，name对应的hash中的key
     # value，name对应的hash中的value

 # 注：
     # hsetnx(name, key, value),当name对应的hash中不存在当前key时则创建（相当于添加）

hmset(name, mapping)

 # 在name对应的hash中批量设置键值对

 # 参数：
     # name，redis的name
     # mapping，字典，如：{'k1':'v1', 'k2': 'v2'}

 # 如：
     # r.hmset('xx', {'k1':'v1', 'k2': 'v2'})

hget(name,key)

# 在name对应的hash中获取根据key获取value

hmget(name, keys, *args)

 # 在name对应的hash中获取多个key的值

 # 参数：
     # name，reids对应的name
     # keys，要获取key集合，如：['k1', 'k2', 'k3']
     # *args，要获取的key，如：k1,k2,k3

 # 如：
     # r.mget('xx', ['k1', 'k2'])
     # 或
     # print r.hmget('xx', 'k1', 'k2')

hgetall(name)

# 获取name对应hash的所有键值

hlen(name)

# 获取name对应的hash中键值对的个数

hkeys(name)

# 获取name对应的hash中所有的key的值

hvals(name)

# 获取name对应的hash中所有的value的值

hexists(name, key)

# 检查name对应的hash是否存在当前传入的key

hdel(name,*keys)

# 将name对应的hash中指定key的键值对删除

hincrby(name, key, amount=1)

 # 自增name对应的hash中的指定key的值，不存在则创建key=amount
 # 参数：
     # name，redis中的name
     # key， hash对应的key
     # amount，自增数（整数）

hincrbyfloat(name, key, amount=1.0)

 # 自增name对应的hash中的指定key的值，不存在则创建key=amount

 # 参数：
     # name，redis中的name
     # key， hash对应的key
     # amount，自增数（浮点数）

 # 自增name对应的hash中的指定key的值，不存在则创建key=amount

hscan(name, cursor=0, match=None, count=None)

 # 增量式迭代获取，对于数据大的数据非常有用，hscan可以实现分片的获取数据，并非一次性将数据全部获取完，从而放置内存被撑爆

 # 参数：
     # name，redis的name
     # cursor，游标（基于游标分批取获取数据）
     # match，匹配指定key，默认None 表示所有的key
     # count，每次分片最少获取个数，默认None表示采用Redis的默认分片个数

 # 如：
     # 第一次：cursor1, data1 = r.hscan('xx', cursor=0, match=None, count=None)
     # 第二次：cursor2, data1 = r.hscan('xx', cursor=cursor1, match=None, count=None)
     # ...
     # 直到返回值cursor的值为0时，表示数据已经通过分片获取完毕

hscan_iter(name, match=None, count=None)

 # 利用yield封装hscan创建生成器，实现分批去redis中获取数据

 # 参数：
     # match，匹配指定key，默认None 表示所有的key
     # count，每次分片最少获取个数，默认None表示采用Redis的默认分片个数

 # 如：
     # for item in r.hscan_iter('xx'):
     #     print item

List操作，redis中的List在在内存中按照一个name对应一个List来存储。如图：

lpush(name,values)

 # 在name对应的list中添加元素，每个新的元素都添加到列表的最左边

 # 如：
     # r.lpush('oo', 11,22,33)
     # 保存顺序为: 33,22,11

 # 扩展：
     # rpush(name, values) 表示从右向左操作

lpushx(name,value)

 # 在name对应的list中添加元素，只有name已经存在时，值添加到列表的最左边

 # 更多：
     # rpushx(name, value) 表示从右向左操作

llen(name)

# name对应的list元素的个数

linsert(name, where, refvalue, value))

 # 在name对应的列表的某一个值前或后插入一个新值

 # 参数：
     # name，redis的name
     # where，BEFORE或AFTER
     # refvalue，标杆值，即：在它前后插入数据
     # value，要插入的数据

r.lset(name, index, value)

 # 对name对应的list中的某一个索引位置重新赋值

 # 参数：
     # name，redis的name
     # index，list的索引位置
     # value，要设置的值

r.lrem(name, value, num)

 # 在name对应的list中删除指定的值

 # 参数：
     # name，redis的name
     # value，要删除的值
     # num，  num=0，删除列表中所有的指定值；
            # num=2,从前到后，删除2个；
            # num=-2,从后向前，删除2个

lpop(name)

 # 在name对应的列表的左侧获取第一个元素并在列表中移除，返回值则是第一个元素

 # 更多：
     # rpop(name) 表示从右向左操作

lindex(name, index)

# 在name对应的列表中根据索引获取列表元素

lrange(name, start, end)

 # 在name对应的列表分片获取数据
 # 参数：
     # name，redis的name
     # start，索引的起始位置
     # end，索引结束位置

ltrim(name, start, end)

 # 在name对应的列表中移除没有在start-end索引之间的值
 # 参数：
     # name，redis的name
     # start，索引的起始位置
     # end，索引结束位置

rpoplpush(src, dst)

 # 从一个列表取出最右边的元素，同时将其添加至另一个列表的最左边
 # 参数：
     # src，要取数据的列表的name
     # dst，要添加数据的列表的name

blpop(keys, timeout)

 # 将多个列表排列，按照从左到右去pop对应列表的元素

 # 参数：
     # keys，redis的name的集合
     # timeout，超时时间，当元素所有列表的元素获取完之后，阻塞等待列表内有数据的时间（秒）, 0 表示永远阻塞

 # 更多：
     # r.brpop(keys, timeout)，从右向左获取数据

brpoplpush(src, dst, timeout=0)

 # 从一个列表的右侧移除一个元素并将其添加到另一个列表的左侧

 # 参数：
     # src，取出并要移除元素的列表对应的name
     # dst，要插入元素的列表对应的name
     # timeout，当src对应的列表中没有数据时，阻塞等待其有数据的超时时间（秒），0 表示永远阻塞

自定义增量迭代

 # 由于redis类库中没有提供对列表元素的增量迭代，如果想要循环name对应的列表的所有元素，那么就需要：
     # 1、获取name对应的所有列表
     # 2、循环列表
 # 但是，如果列表非常大，那么就有可能在第一步时就将程序的内容撑爆，所有有必要自定义一个增量迭代的功能：

 def list_iter(name):
     """
     自定义redis列表增量迭代
     :param name: redis中的name，即：迭代name对应的列表
     :return: yield 返回 列表元素
     """
     list_count = r.llen(name)
     for index in xrange(list_count):
         yield r.lindex(name, index)

 # 使用
 for item in list_iter('pp'):
     print item

Set操作，Set集合就是不允许重复的列表

sadd(name,values)

# name对应的集合中添加元素

scard(name)

# 获取name对应的集合中元素个数

sdiff(keys, *args)

# 在第一个name对应的集合中且不在其他name对应的集合的元素集合

sdiffstore(dest, keys, *args)

# 获取第一个name对应的集合中且不在其他name对应的集合，再将其新加入到dest对应的集合中

sinter(keys, *args)

# 获取多一个name对应集合的并集

sinterstore(dest, keys, *args)

# 获取多一个name对应集合的并集，再讲其加入到dest对应的集合中

sismember(name, value)

# 检查value是否是name对应的集合的成员

smembers(name)

# 获取name对应的集合的所有成员

smove(src, dst, value)

# 将某个成员从一个集合中移动到另外一个集合

spop(name)

# 从集合的右侧（尾部）移除一个成员，并将其返回

srandmember(name, numbers)

# 从name对应的集合中随机获取 numbers 个元素

srem(name, values)

# 在name对应的集合中删除某些值

sunion(keys, *args)

# 获取多一个name对应的集合的并集

sunionstore(dest,keys, *args)

# 获取多一个name对应的集合的并集，并将结果保存到dest对应的集合中

sscan(name, cursor=0, match=None, count=None)
sscan_iter(name, match=None, count=None)

# 同字符串的操作，用于增量迭代分批获取元素，避免内存消耗太大

有序集合，在集合的基础上，为每元素排序；元素的排序需要根据另外一个值来进行比较，所以，对于有序集合，每一个元素有两个值，即：值和分数，分数专门用来做排序。

zadd(name, *args, **kwargs)

 # 在name对应的有序集合中添加元素
 # 如：
      # zadd('zz', 'n1', 1, 'n2', 2)
      # 或
      # zadd('zz', n1=11, n2=22)

zcard(name)

# 获取name对应的有序集合元素的数量

zcount(name, min, max)

# 获取name对应的有序集合中分数 在 [min,max] 之间的个数

zincrby(name, value, amount)

# 自增name对应的有序集合的 name 对应的分数

r.zrange( name, start, end, desc=False, withscores=False, score_cast_func=float)

 # 按照索引范围获取name对应的有序集合的元素

 # 参数：
     # name，redis的name
     # start，有序集合索引起始位置（非分数）
     # end，有序集合索引结束位置（非分数）
     # desc，排序规则，默认按照分数从小到大排序
     # withscores，是否获取元素的分数，默认只获取元素的值
     # score_cast_func，对分数进行数据转换的函数

 # 更多：
     # 从大到小排序
     # zrevrange(name, start, end, withscores=False, score_cast_func=float)

     # 按照分数范围获取name对应的有序集合的元素
     # zrangebyscore(name, min, max, start=None, num=None, withscores=False, score_cast_func=float)
     # 从大到小排序
     # zrevrangebyscore(name, max, min, start=None, num=None, withscores=False, score_cast_func=float)

zrank(name, value)

 # 获取某个值在 name对应的有序集合中的排行（从 0 开始）

 # 更多：
     # zrevrank(name, value)，从大到小排序

zrangebylex(name, min, max, start=None, num=None)

 # 当有序集合的所有成员都具有相同的分值时，有序集合的元素会根据成员的 值 （lexicographical ordering）来进行排序，而这个命令则可以返回给定的有序集合键 key 中， 元素的值介于 min 和 max 之间的成员
 # 对集合中的每个成员进行逐个字节的对比（byte-by-byte compare）， 并按照从低到高的顺序， 返回排序后的集合成员。 如果两个字符串有一部分内容是相同的话， 那么命令会认为较长的字符串比较短的字符串要大

 # 参数：
     # name，redis的name
     # min，左区间（值）。 + 表示正无限； - 表示负无限； ( 表示开区间； [ 则表示闭区间
     # min，右区间（值）
     # start，对结果进行分片处理，索引位置
     # num，对结果进行分片处理，索引后面的num个元素

 # 如：
     # ZADD myzset 0 aa 0 ba 0 ca 0 da 0 ea 0 fa 0 ga
     # r.zrangebylex('myzset', "-", "[ca") 结果为：['aa', 'ba', 'ca']

 # 更多：
     # 从大到小排序
     # zrevrangebylex(name, max, min, start=None, num=None)

zrem(name, values)

# 删除name对应的有序集合中值是values的成员 # 如：zrem('zz', ['s1', 's2'])

zremrangebyrank(name, min, max)

# 根据排行范围删除

zremrangebyscore(name, min, max)

# 根据分数范围删除

zremrangebylex(name, min, max)

# 根据值返回删除

zscore(name, value)

# 获取name对应有序集合中 value 对应的分数

zinterstore(dest, keys, aggregate=None)

# 获取两个有序集合的交集，如果遇到相同值不同分数，则按照aggregate进行操作 # aggregate的值为: SUM MIN MAX

zunionstore(dest, keys, aggregate=None)

# 获取两个有序集合的并集，如果遇到相同值不同分数，则按照aggregate进行操作 # aggregate的值为: SUM MIN MAX

zscan(name, cursor=0, match=None, count=None, score_cast_func=float)
zscan_iter(name, match=None, count=None,score_cast_func=float)

# 同字符串相似，相较于字符串新增score_cast_func，用来对分数进行操作

其他常用操作

delete(*names)
  # 根据删除redis中的任意数据类型 
exists(name)
   # 检测redis的name是否存在 
keys(pattern='*')

 # 根据模型获取redis的name

 # 更多：
     # KEYS * 匹配数据库中所有 key 。
     # KEYS h?llo 匹配 hello ， hallo 和 hxllo 等。
     # KEYS h*llo 匹配 hllo 和 heeeeello 等。
     # KEYS h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo

expire(name ,time)

# 为某个redis的某个name设置超时时间

rename(src, dst)

# 对redis的name重命名为

move(name, db))

# 将redis的某个值移动到指定的db下

randomkey()

# 随机获取一个redis的name（不删除）

type(name)

# 获取name对应值的类型

scan(cursor=0, match=None, count=None)
scan_iter(match=None, count=None)

# 同字符串操作，用于增量迭代获取key

4、管道

redis-py默认在执行每次请求都会创建（连接池申请连接）和断开（归还连接池）一次连接操作，如果想要在一次请求中指定多个命令，则可以使用pipline实现一次请求指定多个命令，并且默认情况下一次pipline 是原子性操作。

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-

 import redis

 pool = redis.ConnectionPool(host='10.211.55.4', port=6379)

 r = redis.Redis(connection_pool=pool)

 # pipe = r.pipeline(transaction=False)
 pipe = r.pipeline(transaction=True)

 pipe.set('name', 'alex')
 pipe.set('role', 'sb')

 pipe.execute()

5、发布订阅

发布者：服务器

订阅者：Dashboad和数据处理

Demo如下：

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import redis

class RedisHelper:

    def __init__(self):
        self.__conn = redis.Redis(host='10.211.55.4')
        self.chan_sub = 'fm104.5'
        self.chan_pub = 'fm104.5'

    def public(self, msg):
        self.__conn.publish(self.chan_pub, msg)
        return True

    def subscribe(self):
        pub = self.__conn.pubsub()
        pub.subscribe(self.chan_sub)
        pub.parse_response()
        return pub

RedisHelper

订阅者：

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-

 from monitor.RedisHelper import RedisHelper

 obj = RedisHelper()
 redis_sub = obj.subscribe()

 while True:
     msg= redis_sub.parse_response()
     print msg

发布者：

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-

 from monitor.RedisHelper import RedisHelper

 obj = RedisHelper()
 obj.public('hello')

更多参见：https://github.com/andymccurdy/redis-py/

http://doc.redisfans.com/

pymsql

pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同。

一、下载安装：

  pip3 install pymysql 

二、使用

1、执行SQL

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import pymysql

 # 创建连接
 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='t1')
 # 创建游标
 cursor = conn.cursor()

 # 执行SQL，并返回收影响行数
 effect_row = cursor.execute("update hosts set host = '1.1.1.2'")

 # 执行SQL，并返回受影响行数
 #effect_row = cursor.execute("update hosts set host = '1.1.1.2' where nid > %s", (1,))

 # 执行SQL，并返回受影响行数
 #effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])

 # 提交，不然无法保存新建或者修改的数据
 conn.commit()

 # 关闭游标
 cursor.close()
 # 关闭连接
 conn.close()

2、获取新创建数据自增ID

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import pymysql

 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='t1')
 cursor = conn.cursor()
 cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])
 conn.commit()
 cursor.close()
 conn.close()

 # 获取最新自增ID
 new_id = cursor.lastrowid

3、获取查询数据

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import pymysql

 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='t1')
 cursor = conn.cursor()
 cursor.execute("select * from hosts")

 # 获取第一行数据
 row_1 = cursor.fetchone()

 # 获取前n行数据
 # row_2 = cursor.fetchmany(3)
 # 获取所有数据
 # row_3 = cursor.fetchall()

 conn.commit()
 cursor.close()
 conn.close()

注：在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：

• cursor.scroll(1,mode='relative')  # 相对当前位置移动
• cursor.scroll(2,mode='absolute') # 相对绝对位置移动

4、fetch数据类型

　　关于默认获取的数据是元祖类型，如果想要或者字典类型的数据，即：

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import pymysql

 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='t1')

 # 游标设置为字典类型
 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
 r = cursor.execute("call p1()")

 result = cursor.fetchone()

 conn.commit()
 cursor.close()
 conn.close()

SQLAchemy

SQLAlchemy是Python编程语言下的一款ORM框架，该框架建立在数据库API之上，使用关系对象映射进行数据库操作，简言之便是：将对象转换成SQL，然后使用数据API执行SQL并获取执行结果。

SQLAlchemy本身无法操作数据库，其必须以来pymsql等第三方插件，Dialect用于和数据API进行交流，根据配置文件的不同调用不同的数据库API，从而实现对数据库的操作，如：

 MySQL-Python
     mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>

 pymysql
     mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]

 MySQL-Connector
     mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>

 cx_Oracle
     oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]

 更多详见：http://docs.sqlalchemy.org/en/latest/dialects/index.html

一、底层处理

使用 Engine/ConnectionPooling/Dialect 进行数据库操作，Engine使用ConnectionPooling连接数据库，然后再通过Dialect执行SQL语句。

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 from sqlalchemy import create_engine

 engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/t1", max_overflow=5)

 # 执行SQL
 # cur = engine.execute(
 #     "INSERT INTO hosts (host, color_id) VALUES ('1.1.1.22', 3)"
 # )

 # 新插入行自增ID
 # cur.lastrowid

 # 执行SQL
 # cur = engine.execute(
 #     "INSERT INTO hosts (host, color_id) VALUES(%s, %s)",[('1.1.1.22', 3),('1.1.1.221', 3),]
 # )

 # 执行SQL
 # cur = engine.execute(
 #     "INSERT INTO hosts (host, color_id) VALUES (%(host)s, %(color_id)s)",
 #     host='1.1.1.99', color_id=3
 # )

 # 执行SQL
 # cur = engine.execute('select * from hosts')
 # 获取第一行数据
 # cur.fetchone()
 # 获取第n行数据
 # cur.fetchmany(3)
 # 获取所有数据
 # cur.fetchall()

二、ORM功能使用

使用 ORM/Schema Type/SQL Expression Language/Engine/ConnectionPooling/Dialect 所有组件对数据进行操作。根据类创建对象，对象转换成SQL，执行SQL。

1、创建表

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
 from sqlalchemy.orm import sessionmaker, relationship
 from sqlalchemy import create_engine

 engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/t1", max_overflow=5)

 Base = declarative_base()

 # 创建单表
 class Users(Base):
     __tablename__ = 'users'
     id = Column(Integer, primary_key=True)
     name = Column(String(32))
     extra = Column(String(16))

     __table_args__ = (
     UniqueConstraint('id', 'name', name='uix_id_name'),
         Index('ix_id_name', 'name', 'extra'),
     )

 # 一对多
 class Favor(Base):
     __tablename__ = 'favor'
     nid = Column(Integer, primary_key=True)
     caption = Column(String(50), default='red', unique=True)

 class Person(Base):
     __tablename__ = 'person'
     nid = Column(Integer, primary_key=True)
     name = Column(String(32), index=True, nullable=True)
     favor_id = Column(Integer, ForeignKey("favor.nid"))

 # 多对多
 class Group(Base):
     __tablename__ = 'group'
     id = Column(Integer, primary_key=True)
     name = Column(String(64), unique=True, nullable=False)
     port = Column(Integer, default=22)

 class Server(Base):
     __tablename__ = 'server'

     id = Column(Integer, primary_key=True, autoincrement=True)
     hostname = Column(String(64), unique=True, nullable=False)

 class ServerToGroup(Base):
     __tablename__ = 'servertogroup'
     nid = Column(Integer, primary_key=True, autoincrement=True)
     server_id = Column(Integer, ForeignKey('server.id'))
     group_id = Column(Integer, ForeignKey('group.id'))

 def init_db():
     Base.metadata.create_all(engine)

 def drop_db():
     Base.metadata.drop_all(engine)

ForeignKeyConstraint(['other_id'], ['othertable.other_id']),

2、操作表

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
 from sqlalchemy.orm import sessionmaker, relationship
 from sqlalchemy import create_engine

 engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/t1", max_overflow=5)

 Base = declarative_base()

 # 创建单表
 class Users(Base):
     __tablename__ = 'users'
     id = Column(Integer, primary_key=True)
     name = Column(String(32))
     extra = Column(String(16))

     __table_args__ = (
     UniqueConstraint('id', 'name', name='uix_id_name'),
         Index('ix_id_name', 'name', 'extra'),
     )

     def __repr__(self):
         return "%s-%s" %(self.id, self.name)

 # 一对多
 class Favor(Base):
     __tablename__ = 'favor'
     nid = Column(Integer, primary_key=True)
     caption = Column(String(50), default='red', unique=True)

     def __repr__(self):
         return "%s-%s" %(self.nid, self.caption)

 class Person(Base):
     __tablename__ = 'person'
     nid = Column(Integer, primary_key=True)
     name = Column(String(32), index=True, nullable=True)
     favor_id = Column(Integer, ForeignKey("favor.nid"))
     # 与生成表结构无关，仅用于查询方便
     favor = relationship("Favor", backref='pers')

 # 多对多
 class ServerToGroup(Base):
     __tablename__ = 'servertogroup'
     nid = Column(Integer, primary_key=True, autoincrement=True)
     server_id = Column(Integer, ForeignKey('server.id'))
     group_id = Column(Integer, ForeignKey('group.id'))
     group = relationship("Group", backref='s2g')
     server = relationship("Server", backref='s2g')

 class Group(Base):
     __tablename__ = 'group'
     id = Column(Integer, primary_key=True)
     name = Column(String(64), unique=True, nullable=False)
     port = Column(Integer, default=22)
     # group = relationship('Group',secondary=ServerToGroup,backref='host_list')

 class Server(Base):
     __tablename__ = 'server'

     id = Column(Integer, primary_key=True, autoincrement=True)
     hostname = Column(String(64), unique=True, nullable=False)

 def init_db():
     Base.metadata.create_all(engine)

 def drop_db():
     Base.metadata.drop_all(engine)

 Session = sessionmaker(bind=engine)
 session = Session()

 表结构+连接数据库

表结构+连接数据库

•增

 obj = Users(name="alex0", extra='sb')
 session.add(obj)
 session.add_all([
     Users(name="alex1", extra='sb'),
     Users(name="alex2", extra='sb'),
 ])
 session.commit()

•删

 session.query(Users).filter(Users.id > 2).delete()
 session.commit()

•改

 session.query(Users).filter(Users.id > 2).update({"name" : ""})
 session.query(Users).filter(Users.id > 2).update({Users.name: Users.name + ""}, synchronize_session=False)
 session.query(Users).filter(Users.id > 2).update({"num": Users.num + 1}, synchronize_session="evaluate")
 session.commit()

•查

 ret = session.query(Users).all()
 ret = session.query(Users.name, Users.extra).all()
 ret = session.query(Users).filter_by(name='alex').all()
 ret = session.query(Users).filter_by(name='alex').first()

•其他

 #　条件
 ret = session.query(Users).filter_by(name='alex').all()
 ret = session.query(Users).filter(Users.id > 1, Users.name == 'eric').all()
 ret = session.query(Users).filter(Users.id.between(1, 3), Users.name == 'eric').all()
 ret = session.query(Users).filter(Users.id.in_([1,3,4])).all()
 ret = session.query(Users).filter(~Users.id.in_([1,3,4])).all()
 ret = session.query(Users).filter(Users.id.in_(session.query(Users.id).filter_by(name='eric'))).all()
 from sqlalchemy import and_, or_
 ret = session.query(Users).filter(and_(Users.id > 3, Users.name == 'eric')).all()
 ret = session.query(Users).filter(or_(Users.id < 2, Users.name == 'eric')).all()
 ret = session.query(Users).filter(
     or_(
         Users.id < 2,
         and_(Users.name == 'eric', Users.id > 3),
         Users.extra != ""
     )).all()

 # 通配符
 ret = session.query(Users).filter(Users.name.like('e%')).all()
 ret = session.query(Users).filter(~Users.name.like('e%')).all()

 # 限制
 ret = session.query(Users)[1:2]

 # 排序
 ret = session.query(Users).order_by(Users.name.desc()).all()
 ret = session.query(Users).order_by(Users.name.desc(), Users.id.asc()).all()

 # 分组
 from sqlalchemy.sql import func

 ret = session.query(Users).group_by(Users.extra).all()
 ret = session.query(
     func.max(Users.id),
     func.sum(Users.id),
     func.min(Users.id)).group_by(Users.name).all()

 ret = session.query(
     func.max(Users.id),
     func.sum(Users.id),
     func.min(Users.id)).group_by(Users.name).having(func.min(Users.id) >2).all()

 # 连表

 ret = session.query(Users, Favor).filter(Users.id == Favor.nid).all()

 ret = session.query(Person).join(Favor).all()

 ret = session.query(Person).join(Favor, isouter=True).all()

 # 组合
 q1 = session.query(Users.name).filter(Users.id > 2)
 q2 = session.query(Favor.caption).filter(Favor.nid < 2)
 ret = q1.union(q2).all()

 q1 = session.query(Users.name).filter(Users.id > 2)
 q2 = session.query(Favor.caption).filter(Favor.nid < 2)
 ret = q1.union_all(q2).all()

更多功能参见文档，猛击这里下载PDF

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 from sqlalchemy import create_engine,and_,or_,func,Table
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy import Column, Integer, String,ForeignKey,UniqueConstraint,DateTime
 from  sqlalchemy.orm import sessionmaker,relationship

 Base = declarative_base() #生成一个SqlORM 基类

 # 服务器账号和组
 # HostUser2Group = Table('hostuser_2_group',Base.metadata,
 #     Column('hostuser_id',ForeignKey('host_user.id'),primary_key=True),
 #     Column('group_id',ForeignKey('group.id'),primary_key=True),
 # )

 # 用户和组关系表，用户可以属于多个组，一个组可以有多个人
 UserProfile2Group = Table('userprofile_2_group',Base.metadata,
     Column('userprofile_id',ForeignKey('user_profile.id'),primary_key=True),
     Column('group_id',ForeignKey('group.id'),primary_key=True),
 )

 # 程序登陆用户和服务器账户，一个人可以有多个服务器账号，一个服务器账号可以给多个人用
 UserProfile2HostUser= Table('userprofile_2_hostuser',Base.metadata,
     Column('userprofile_id',ForeignKey('user_profile.id'),primary_key=True),
     Column('hostuser_id',ForeignKey('host_user.id'),primary_key=True),
 )

 class Host(Base):
     __tablename__='host'
     id = Column(Integer,primary_key=True,autoincrement=True)
     hostname = Column(String(64),unique=True,nullable=False)
     ip_addr = Column(String(128),unique=True,nullable=False)
     port = Column(Integer,default=22)
     def __repr__(self):
         return  "<id=%s,hostname=%s, ip_addr=%s>" %(self.id,
                                                     self.hostname,
                                                     self.ip_addr)

 class HostUser(Base):
     __tablename__ = 'host_user'
     id = Column(Integer,primary_key=True)
     AuthTypes = [
         (u'ssh-passwd',u'SSH/Password'),
         (u'ssh-key',u'SSH/KEY'),
     ]
     # auth_type = Column(ChoiceType(AuthTypes))
     auth_type = Column(String(64))
     username = Column(String(64),unique=True,nullable=False)
     password = Column(String(255))

     host_id = Column(Integer,ForeignKey('host.id'))

     # groups = relationship('Group',
     #                       secondary=HostUser2Group,
     #                       backref='host_list')

     __table_args__ = (UniqueConstraint('host_id','username', name='_host_username_uc'),)

     def __repr__(self):
         return  "<id=%s,name=%s>" %(self.id,self.username)

 class Group(Base):
     __tablename__ = 'group'
     id = Column(Integer,primary_key=True)
     name = Column(String(64),unique=True,nullable=False)
     def __repr__(self):
         return  "<id=%s,name=%s>" %(self.id,self.name)

 class UserProfile(Base):
     __tablename__ = 'user_profile'
     id = Column(Integer,primary_key=True)
     username = Column(String(64),unique=True,nullable=False)
     password = Column(String(255),nullable=False)
     # host_list = relationship('HostUser',
     #                       secondary=UserProfile2HostUser,
     #                       backref='userprofiles')
     # groups = relationship('Group',
     #                       secondary=UserProfile2Group,
     #                       backref='userprofiles')
     def __repr__(self):
         return  "<id=%s,name=%s>" %(self.id,self.username)

 class AuditLog(Base):
     __tablename__ = 'audit_log'
     id = Column(Integer,primary_key=True)
     userprofile_id = Column(Integer,ForeignKey('user_profile.id'))
     hostuser_id = Column(Integer,ForeignKey('host_user.id'))
     action_choices2 = [
         (u'cmd',u'CMD'),
         (u'login',u'Login'),
         (u'logout',u'Logout'),
     ]
     action_type = Column(ChoiceType(action_choices2))
     #action_type = Column(String(64))
     cmd = Column(String(255))
     date = Column(DateTime)

     # user_profile = relationship("UserProfile")
     #bind_host = relationship("BindHost")

 engine = create_engine("mysql+pymsql://root:123@localhost:3306/stupid_jumpserver",echo=False)
 Base.metadata.create_all(engine) #创建所有表结构

表结构操作练习

Paramiko

paramiko模块，基于SSH用于连接远程服务器并执行相关操作。

一、安装

pip3 install paramiko

二、使用

SSHClient

用于连接远程服务器并执行基本命令

基于用户名密码连接：

 import paramiko

 # 创建SSH对象
 ssh = paramiko.SSHClient()
 # 允许连接不在know_hosts文件中的主机
 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 # 连接服务器
 ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', password='')

 # 执行命令
 stdin, stdout, stderr = ssh.exec_command('ls')
 # 获取命令结果
 result = stdout.read()

 # 关闭连接
 ssh.close()

 import paramiko

 transport = paramiko.Transport(('hostname', 22))
 transport.connect(username='wupeiqi', password='')

 ssh = paramiko.SSHClient()
 ssh._transport = transport

 stdin, stdout, stderr = ssh.exec_command('df')
 print stdout.read()

 transport.close()

SSHClient 封装 Transport

基于公钥密钥连接：

 import paramiko

 private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')

 # 创建SSH对象
 ssh = paramiko.SSHClient()
 # 允许连接不在know_hosts文件中的主机
 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 # 连接服务器
 ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', key=private_key)

 # 执行命令
 stdin, stdout, stderr = ssh.exec_command('df')
 # 获取命令结果
 result = stdout.read()

 # 关闭连接
 ssh.close()

 import paramiko

 private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')

 transport = paramiko.Transport(('hostname', 22))
 transport.connect(username='wupeiqi', pkey=private_key)

 ssh = paramiko.SSHClient()
 ssh._transport = transport

 stdin, stdout, stderr = ssh.exec_command('df')

 transport.close()

SSHClient 封装 Transport

SFTPClient

用于连接远程服务器并执行上传下载

基于用户名密码上传下载：

 import paramiko

 transport = paramiko.Transport(('hostname',22))
 transport.connect(username='wupeiqi',password='')

 sftp = paramiko.SFTPClient.from_transport(transport)
 # 将location.py 上传至服务器 /tmp/test.py
 sftp.put('/tmp/location.py', '/tmp/test.py')
 # 将remove_path 下载到本地 local_path
 sftp.get('remove_path', 'local_path')

 transport.close()

基于公钥密钥上传下载：

 import paramiko

 private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')

 transport = paramiko.Transport(('hostname', 22))
 transport.connect(username='wupeiqi', pkey=private_key )

 sftp = paramiko.SFTPClient.from_transport(transport)
 # 将location.py 上传至服务器 /tmp/test.py
 sftp.put('/tmp/location.py', '/tmp/test.py')
 # 将remove_path 下载到本地 local_path
 sftp.get('remove_path', 'local_path')

 transport.close()

 #!/usr/bin/env python
 # -*- coding:utf-8 -*-
 import paramiko
 import uuid

 class SSHConnection(object):

     def __init__(self, host='172.16.103.191', port=22, username='wupeiqi',pwd=''):
         self.host = host
         self.port = port
         self.username = username
         self.pwd = pwd
         self.__k = None

     def create_file(self):
         file_name = str(uuid.uuid4())
         with open(file_name,'w') as f:
             f.write('sb')
         return file_name

     def run(self):
         self.connect()
         self.upload('/home/wupeiqi/tttttttttttt.py')
         self.rename('/home/wupeiqi/tttttttttttt.py', '/home/wupeiqi/ooooooooo.py)
         self.close()

     def connect(self):
         transport = paramiko.Transport((self.host,self.port))
         transport.connect(username=self.username,password=self.pwd)
         self.__transport = transport

     def close(self):

         self.__transport.close()

     def upload(self,target_path):
         # 连接，上传
         file_name = self.create_file()

         sftp = paramiko.SFTPClient.from_transport(self.__transport)
         # 将location.py 上传至服务器 /tmp/test.py
         sftp.put(file_name, target_path)

     def rename(self, old_path, new_path):

         ssh = paramiko.SSHClient()
         ssh._transport = self.__transport
         # 执行命令
         cmd = "mv %s %s" % (old_path, new_path,)
         stdin, stdout, stderr = ssh.exec_command(cmd)
         # 获取命令结果
         result = stdout.read()

     def cmd(self, command):
         ssh = paramiko.SSHClient()
         ssh._transport = self.__transport
         # 执行命令
         stdin, stdout, stderr = ssh.exec_command(command)
         # 获取命令结果
         result = stdout.read()
         return result

 ha = SSHConnection()
 ha.run()

Demo

 # 对于更多限制命令，需要在系统中设置
 /etc/sudoers

 Defaults    requiretty
 Defaults:cmdb    !requiretty

 import paramiko
 import uuid

 class SSHConnection(object):

     def __init__(self, host='192.168.11.61', port=22, username='alex',pwd='alex3714'):
         self.host = host
         self.port = port
         self.username = username
         self.pwd = pwd
         self.__k = None

     def run(self):
         self.connect()
         pass
         self.close()

     def connect(self):
         transport = paramiko.Transport((self.host,self.port))
         transport.connect(username=self.username,password=self.pwd)
         self.__transport = transport

     def close(self):
         self.__transport.close()

     def cmd(self, command):
         ssh = paramiko.SSHClient()
         ssh._transport = self.__transport
         # 执行命令
         stdin, stdout, stderr = ssh.exec_command(command)
         # 获取命令结果
         result = stdout.read()
         return result

     def upload(self,local_path, target_path):
         # 连接，上传
         sftp = paramiko.SFTPClient.from_transport(self.__transport)
         # 将location.py 上传至服务器 /tmp/test.py
         sftp.put(local_path, target_path)

 ssh = SSHConnection()
 ssh.connect()
 r1 = ssh.cmd('df')
 ssh.upload('s2.py', "/home/alex/s7.py")
 ssh.close()

Demo