目的
使用python做自动化测试,使用python得numpy,pandas,http等库来post数据,并且自动产生随机数字,后转化成json上传,并用nodejs做server接收测试,当然也可以用go,java,都一样
1、产生随机数:import time
x = random.randint(65,71)
print(x)
为了产生比较正常得随机心率数据,范围使用65到71
2、http post两种方法,使用request 或者httpclient
import requests
s = requests.session()
#print(s.headers)
headers1 = {
'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:54.0) Gecko/20100101 Firefox/54.0',
'Content-Type': 'application/json'
}
response = s.post(url1,data=json1, headers=headers1,timeout=10)
超时时间设置为10s
3、json post上传时需要json数据,需要将字典转换成json
import json
str = json.dumps({'userid':1})
print(str)
使用dumps函数就可以立刻将python字典格式转化成json字符串
4、show me the codeimport numpy as np
import random
import requests
import time
import pandas as pd
import json
import http.client,urllib.parse
url = "http://39.103.188.46:8082/hrv"
url1 = "http://127.0.0.1:8000/hrv"
def post2():
str = json.dumps({'userid':1})
print(str)
headers = {"Content-type": "application/json","Accept": "text/plain"}
conn = http.client.HTTPConnection("127.0.0.1",8000)
conn.request('POST', "/hrv", str, headers)
response = conn.getresponse()
print(response.status, response.reason)
data = response.read().decode('utf-8')
print(data)
conn.close()
def post(datain):
s = requests.session()
#print(s.headers)
headers1 = {
'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:54.0) Gecko/20100101 Firefox/54.0',
'Content-Type': 'application/json'
}
#json = pd.DataFrame.to_json(datain)
json1 = json.dumps(datain) # 转换为json
response = s.post(url1,data=json1, headers=headers1,timeout=10)
print(response)
print(response.content)
data = {'Id': 116,'Type':3,'Device':'B00007','Data':[]}
nowtime = time.mktime(time.localtime()) - 1000*60 *6 *60 # 往前推一个小时
number = 6 * 60 #一分钟6个数据,一共60分钟 360个数据
for i in range(number):
#x=np.append(x,)
data['Data'].insert(0,{'heart':random.randint(65,71), 'Time':nowtime+i*166})
post(data)
5、nodejs server
实际上我们使用得是go server 做心率服务,这里简单使用nodejs server来接收数据测试,测试人员可以简单使用python,nodejs,go 等做server
var express = require('express');
var cors = require('cors');
var app = express();//创建express实例
app.use(cors());//为了解决跨域问题
var http = require('http').Server(app);
//var httpget = require('http');
var bodyParser = require('body-parser');
app.use(bodyParser.json({limit: '1mb'}));
app.use(bodyParser.urlencoded({
extended: true
}));
//var session = require('express-session');
/*
app.use(session({
secret: 'secret',
resave: true,// don't save session if unmodified
saveUninitialized: false,// don't create session until something stored
cookie: {
maxAge: 1000 * 60 * 10 //过期时间设置(单位毫秒)
}
}));
*/
app.use(express.static(__dirname));
app.post("/hrv",function(req,res){
console.log(req.body);
res.send("{ret:1}");
});
app.get("/",function(req,res){
res.send("{ret:ok}");
});
http.listen(8000, function () {
console.log('listening on *:8000');
});
收到数据打印,如下图所示