1.python的mysql连接

def mysql(sql02,sql01=None,host="localhost",name="root",pwd="Wnxy100",database="mydata",charset='utf8'): 
    import pymysql
    data=None
    # sql01="use "+sql01 #库名
    con=pymysql.connect(host,name,pwd) #1、连接数据库
    cur=con.cursor() #2、创建游标
    try: #异常抓取
        if sql01!=None:
            cur.execute(sql01) #多条sql作事务
        cur.execute(sql02) #3、执行SQL语句
        if sql02[:6].lower()=="select": #判断是否为查询语言
            data=cur.fetchall() #获取查询的存储信息
            # data=cur.fetchmany(3) #获取查询的部分存储信息,参数：前三条。
    except Exception as e: #基类异常捕获
        print(e)
        con.rollback() #事务回滚
    con.commit() #4、提交事务
    #5、关闭游标，连接
    cur.close()
    con.close()
    return data  #返回查询结果

2.爬虫

def Climb(urlx):
    import urllib.request
    import re,os

    num=1
    path=urlx #找到图片地址
    url=urllib.request.urlopen(path) #打开网址的内容
    date_1=url.read() #读取网站内容
    #筛选图片,返回的图片地址列表
    img_list=re.findall(r"http://[\S]*jpg",repr(date_1)) #正则,解析
    for i in img_list:
        if num<=100: #如果保存图片超过100就停止
            # print(i)
            try:
                imge=urllib.request.urlopen(i) #打开图片内容
                date=imge.read() #读取图片内容
            except Exception as e:
                print(e)
                print("下载出错。")
            with open("F:\\test\\{0}.jpg".format(num),"wb") as f:
                f.write(date) #保存图片到本地
                print("正在下载第{0}张图片".format(num))
                num+=1
    print("下载完成！")
    
if __name__ == "__main__":
    url="http://www.jj20.com/bz/dwxz"
    Climb(url)

3.从外部接收字符串，利用多进程的队列方式通信并输出。

import multiprocessing,time
que=multiprocessing.Queue()
def write(que,str):
    for i in str:
        que.put(i)
def read(que):
    time.sleep(2)
    li=[]
    for j in range(que.qsize()):
        li.append(que.get())
    str02="".join(li)
    print(str02)

if __name__ == "__main__":
    str=input("请输入你要读写的字符串：")
    p1=multiprocessing.Process(target=write,args=(que,str))
    p2=multiprocessing.Process(target=read,args=(que,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    print("执行完成！")