paramiko模块
ssh 密钥连接连接
import paramiko
private_key =pramiko.RSAKey.from_private_key_file("私钥路径")
ssh =paramiko.SShClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname=",port=",username=",pkey=private_key)
#ssh.connect(hostname=",port=",username=",password=")
stdin,stdout,stderr =ssh.exec_command("")
result =stdout.read()
ssh.close(0
scp 密钥连接传输
import paramiko
private_key =pramiko.RSAKey.from_private_key_file("私钥路径")
transport =paramiko.Transport("","")
transport.connect(username="",pkey=private_file)
#transport.connect(username="",password="")
sftp =paramiko.SFTPClient.from_transport(transport)
sftp.put("原文件路径","目标文件路径")
sftp.get("目标文件路径","本地路径")
transport.close()
进程：程序调用资源的一个集合
线程：程序指令的集合
进程与线程的区别
主线程创建子线程，线程间相互独立
线程共享内存，进程内存独立
启动线程比进程快
线程可以直接通信，进程需要中间进程
线程可以操控其他线程，进程只能操控子进程
多线程
import threading
import time
def run(n):
print("task",n)
time.sleep(2)
t1 =threading.Thread(target=run,args=("t1",)) 并发执行
t1.start()
t2 =threading.Thread(target=run,args=("t2",))
t2.start()
# run("t1") 串行执行
# run("t2")
多线程的类方法实现
import threading
class MyThread(threading.Thread):
def __init__(self,n):
super(MyThread,self).__init__()
self.n =n
def run(self):
print("runint task",self.n)
t1 =MyThread("t1")
t2 =MyThread("t2")
t1.start()
t2.start()
同时启动多个并发任务并获取每个线程的执行完成
import threading,time
def run(n):
print("task",n)
time.sleep(2)
start_time =time.time()
t_obj =[]
for i in range(50):
t =threading.Thread(target=run,args=("t-%s"%i,))
#t.setDaemon(True)设置守护线程，等待非守护线程结束后该线程就结束
t.start()
t_obj.append(t)
for t in t_obj:
t.join() 等待相应线程的执行完成
print("cost",time.time()-start_time)
lock =threading.Lock() 实例化线程锁
lock =threading.RLock() 实例化递归锁
lock.acquire() 申请线程锁
lock.release() 释放线程锁
semaphore = threading.BoundedSemaphore(5) #最多允许5个线程同时运行
semaphore.acquire()
semaphore.release()
队列
import queue
# q =queue.Queue() 先进先出队列
# q =queue.LifoQueue() 后进先出队列
q =queue.PriorityQueue(maxsize=3) 自由设置优先级队列
q.put((1,"alex")) 元组形式传递优先级和消息内容，第一个值越小优先级越高
q.put_nowait(2) 当队列放满时，直接返回
q.put(1) 放入消息内容
q.put(2)
q.get(block=False,timeout=1) 获取消息内容，block=false代表没有值时直接返回，timeout=1表示等待时间到1秒后就返回
q.get_nowait() 获取消息时，队列为空就返回
print(q.empty()) 检测队列是否为空
print(q.full()) 检测队列是否放满了
print(q.qsize()) 检测队列中消息的个数
生产者消费者模型
import threading,queue,time
q =queue.Queue(maxsize=10)
def product(name):
count = 1
while True:
q.put("骨头%d" ,count)
print("[%s]生产了骨头%d"%(name,count))
count +=1
time.sleep(2)
def consumer(name):
while True:
print("[%s]取了骨头[%s]，并吃了它"%(name,q.get()))
time.sleep(1)
t =threading.Thread(target=product,args=("alex",))
t2 =threading.Thread(target=consumer,args=("jack",))
t3 =threading.Thread(target=consumer,args=("wangnima",))
t.start()
t2.start()
t3.start()