nopnop2002
89 lines
2.5 KiB
Python
89 lines
2.5 KiB
Python
#!/usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
# Simple REST Server
|
|
|
|
import os
|
|
import sys
|
|
import json
|
|
import datetime
|
|
import werkzeug
|
|
import tornado.httpserver
|
|
import tornado.ioloop
|
|
import tornado.options
|
|
import tornado.web
|
|
|
|
from tornado.options import define, options
|
|
define("port", default=8000, help="run on the given port", type=int)
|
|
define("lines", default=20, help="number of lines displayed", type=int)
|
|
|
|
database = []
|
|
|
|
class IndexHandler(tornado.web.RequestHandler):
|
|
def get(self):
|
|
global database
|
|
items = []
|
|
for data in database:
|
|
#print("{}".format(data))
|
|
datetime = data[0].split()
|
|
#print("data={} datetime={}".format(data[0], datetime))
|
|
|
|
items.append({
|
|
"date": datetime[0],
|
|
"time": datetime[1],
|
|
"id": data[1],
|
|
"frame": data[2],
|
|
"value": data[3]
|
|
})
|
|
#print("items={}".format(items))
|
|
self.render("index.html", lines=options.lines, items=items)
|
|
|
|
#curl -X POST -H "Content-Type: application/json" -d '{"canid":101, "frame":"standard" , "data": [1,2,3,4,5,6,7,8]}' http://192.168.10.43:8000/post
|
|
class PostHandler(tornado.web.RequestHandler):
|
|
def post(self):
|
|
#print("{}".format(self.request.body))
|
|
function = sys._getframe().f_code.co_name
|
|
dict = tornado.escape.json_decode(self.request.body)
|
|
print("{} dict={}".format(function, dict))
|
|
|
|
items = []
|
|
now = datetime.datetime.now()
|
|
items.append(now.strftime("%Y/%m/%d %H:%M:%S"))
|
|
if ("canid" in dict):
|
|
print("{} canid=0x{:x}".format(function, dict['canid']))
|
|
items.append(dict['canid'])
|
|
|
|
if ("frame" in dict):
|
|
print("{} frame={}".format(function, dict['frame']))
|
|
items.append(dict['frame'])
|
|
|
|
if ("data" in dict):
|
|
print("{} data length={}".format(function, len(dict['data'])))
|
|
print("{} data={}".format(function, dict['data']))
|
|
items.append(dict['data'])
|
|
|
|
global database
|
|
#print("{} {} {}".format(type(database), len(database), database))
|
|
print("lines={}".format(options.lines))
|
|
#if(len(database) >= 20):
|
|
if(len(database) >= options.lines):
|
|
database.pop(0)
|
|
database.append(items)
|
|
|
|
self.write(json.dumps({"result":"ok"}))
|
|
|
|
if __name__ == "__main__":
|
|
tornado.options.parse_command_line()
|
|
print("port={}".format(options.port))
|
|
print("lines={}".format(options.lines))
|
|
app = tornado.web.Application(
|
|
handlers=[
|
|
(r"/", IndexHandler),
|
|
(r"/post", PostHandler),
|
|
],
|
|
template_path=os.path.join(os.getcwd(), "templates"),
|
|
debug=True
|
|
)
|
|
http_server = tornado.httpserver.HTTPServer(app)
|
|
http_server.listen(options.port)
|
|
tornado.ioloop.IOLoop.current().start()
|