接口开发

接口开发需要用到第三方模块flask.

1、登录的接口。

import flaskimport jsonimport pymysqlimport hashlibserver = flask.Flask(__name__)#新建一个服务，把当前这个python文件当做一个服务

def my_db(sql):    conn = pymysql.connect(host='XX.XXX.XX.XX',user='XXX',password='XXXXXX',                    db='XXX',port=3306,charset='utf8',autocommit=True)    cur = conn.cursor(pymysql.cursors.DictCursor)    cur.execute(sql)    res = cur.fetchone()    cur.close()    conn.close()    return res

def my_md5(s,salt=''):    s = s+salt    news = str(s).encode()    m = hashlib.md5(news)    return m.hexdigest()

@server.route('/login',methods=['get'])def hello():    uname = flask.request.values.get('username')    pd = flask.request.values.get('passwd')    sql = 'select * from su_user where login_name="%s"'%uname    res = my_db(sql)    print(res)    if res:        if my_md5(pd) == res.get('pwd'):            res = {"code":0,"msg":"登录成功！"}        else:            res = {"code":1,"msg":"密码错误！"}    else:        res = {'code':2,"msg":"用户不存在"}    return json.dumps(res,ensure_ascii=False,indent=4)

#别人访问时，需要输入我自己的IP地址作为url中的IP，端口号为8999，这样别人也能访问我开发的接口；#debug=True：代表修改完代码后不需要手动重启服务，直接就自动重启了server.run(host='0.0.0.0',port=8999,debug=True)#server.run()

2、入参不同的接口

import flaskimport toolsimport json,redis

@server.route('/api/stu')def get_stu():    username = flask.request.values.get('name')#默认get不到的话，返回的值就是None    age = flask.request.values.get('age')    if username and age:        sql = "select * from app_student where name='%s' and age='%s'" % (username, age)    elif not username and age:        sql = "select * from app_student where age='%s'" % age    elif username and not age:        sql = "select * from app_student where name='%s'" % username    else:        sql = "select * from app_student"    res = tools.my_db2(sql)    return json.dumps(res,ensure_ascii=False,indent=4)

server.run(host='0.0.0.0',port=8999,debug=True)

3、入参是json类型的

@server.route('/api/add_stu',methods=['post'])def add_stu():    if flask.request.is_json:#判断入参是否是json类型的        session_id = flask.request.json.get('session_id')        name= flask.request.json.get('name')        phone = flask.request.json.get('phone')        grade = flask.request.json.get('grade')        addr = flask.request.json.get('addr','北京')        sex = flask.request.json.get('sex','男')        age = flask.request.json.get('age',18)        gold = flask.request.json.get('gold',1000)        if session_id and name and phone and grade:            login_tag , data = check_session(session_id)            if login_tag:                insert_sql="insert into `jxz`.`app_student` ( `name`, `sex`," \                           " `age`, `addr`, `grade`, `phone`, `gold`)" \                           " values ( '%s', '%s', '%s', '%s', '%s', '%s', '%s');"%(name,sex,age,addr,grade,phone,gold)                tools.my_db(insert_sql)                res = {'code':0,'msg':'学生信息添加成功'}            else:                res = data

        else:            res = {'code':3,'msg':'必填参数未填，请查看接口文档！'}    else:        res = {'code':5,'msg':'入参是json类型的！'}    return json.dumps(res, ensure_ascii=False)

4、入参是上传文件类型的

@server.route('/api/upload',methods=['post'])def upload():    session_id = flask.request.values.get('session_id')    file = flask.request.files.get('file_name')    if session_id and file:        login_tag, data = check_session(session_id)        if login_tag:            new_file_name = '%s_%s'%(int(time.time()),file.filename)#file.filename能获取到上传的文件名            #防止文件名重复，所以把文件名前面加上了时间戳            abs_file_path = os.path.join(setting.UPLOAD_DIR,new_file_name)            #拼文件的绝对路径，这样子就放到了uploads目录下            file.save(abs_file_path)#保存文件            res = {'code':0,'msg':'上传文件成功！'}        else:            res = data    else:        res = {'code':3,'msg':'必填参数未填，请查看接口文档！'}    return json.dumps(res, ensure_ascii=False)

3、搭建框架思想例如：图书管理系统

写日志

1、pip install nnlog

import nnlog#nnlog.Logger.words='哈哈哈哈'#默认打印debug级别的日志，默认when='D'表示每天产生日志，默认backCount=5代表保留最近5天的日志#自动生成book_server.log文件，并且里面永远存最新的日志log = nnlog.Logger('book_server.log',when='S',backCount=3)

# debug#最低级日志# info倒数第二级# warning整数第二级# error#最高级日志#log.surprise()log.debug('xxx值是什么')log.info('调用了什么xxx')log.warning('xx警告！')log.error('xxx出错！')

注意：默认是打印debug级别，那么会把debug、info、warning、error级别的日志都打印出来
           如果指定打印是warning级别，那么会把warning和info级别的日志打印出来。
总结：会把指定的级别和比它自己高级别的日志打印出来。

发邮件

1、导入yagmail模块，导入的模块不可以直接“pip install yagmail”,因为发送中文附件时，会报乱码，所以需要导入.whl形式结尾的文件

需要手动安装：pip install +文件绝对路径 （pip install E:\python20181026\yagmail-0.10.212-py2.py3-none-any.whl）

2、需要知道发送邮箱的号码，与邮箱的授权码（不是邮箱登录密码），

代码如下：

import yagmailusername='xxxxx@163.com'password='XXXXXXXX'#生成授权码，qq、163、126都是授权码

mail_server = 'smtp.163.com'# mail_server = 'smtp.qq.com'# mail_server = 'smtp.126.com'

m = yagmail.SMTP(user=username,password=password,host=mail_server)            # smtp_ssl=True，如果邮箱使用了安全协议，就需要加这个            #qq邮箱就是使用了安全协议

to = ['1xxx722@qq.com','wangxxx416516@163.com','51xx5@qq.com']cc = ['6137xx17@qq.com','11xx42722@qq.com','136xx4@qq.com']

#to:收件人； cc:抄送；subject：主题；contents：内容；attachments：附件m.send(to=to,cc=cc,subject='今天吃了吗',       contents='今天吃鱼肉了吗，吃饱没',       attachments=r'tools.py')

发送网络请求

需要导入requests模块 pip install requests

1、发送get请求

import requestsimport randomurl='http://127.0.0.1:8999/api/upload'data = {'username':'testuser1','passwd':'111111'}r = requests.get(url,params=data) #发get请求r.json()#如果你请求的是一个接口的话，返回的是json，那就给你转成字典r.text()#返回的是字符串

2、发送post请求

import requestsimport randomurl='http://127.0.0.1:8999/api/upload'data = {'username':'testuser1','passwd':'111111'}r = requests.post(url,data=data) #发post请求

3、入参是json类型的

import requestsimport randomurl='http://127.0.0.1:8999/api/upload'r = requests.post(url,data=data) #发post请求

 data = { "session_id":"6ab8785039dcf50fb11c53acc1db7648", "name":"zhouyongbo%s"%random.randint(1,99), "phone":"111211345%02d"%random.randint(1,99), "grade":"天秤座" }r = requests.post(url,json=data) #入参是json类型的

4、上传文件

r = requests.post(url,              data={'session_id':'6ab8785039dcf50fb11c53acc1db7648'},              files={'file_name':open('account.xls','rb')  }              )

5、请求中带有cookie的

requests.get(url,headers={'cookie':'hdfjghdkghkdhgkdh'})

requests.get(url,cookies={'pt2ggui':'o0511402865','RK':'JQZpwBp1by'}) （使用不方便，很少用）

6、下载文件

url='https://qiniuuwmp3.changba.com/1127063572.mp4'r = requests.get(url)f = open('sdfsdf.mp4','wb')f.write(r.content) #r.content  #二进制，下载图片、下载文件的时候用f.close()

手动添加环境变量 

import sys,os#手动加入环境变量的，这样的话，在其他人的电脑上运行就没有问题了BASE_PATH=os.path.dirname(os.path.abspath(__file__))sys.path.insert(0,BASE_PATH)