python3 supervisor 接口_ubutu tornado python3.7.5 nginx supervisor 部署web api

环境:

1、Ubuntu 服务器

2、python3.7.5

安装

1、python3.7.5

安装的话还是比较简单,流程大致是

./configure ->make && make install ->创建python软连接  pip软连接

安装起来倒是简单,安装完成运行才会遇到各种各样的问题,缺少插件啥的。

1.1、下载包  python3.7.5

1.2、问题

a、No module named '_ctypes'

sudo apt-get install libffi-dev 需不需要重新安装看ok不

b、No module named _ssl

安装之前修改下安装包里面的modules里面的setup.dist文件的内容

ex:  /usr/web/tornadoTest/package/Python-3.7.5/Modules/Setup.dist   我的安装目录

大约 206行左右,去掉注释即可

然后再重新安装,等pip这些可以用起来了在开始下一步。

2、安装所需的package

需要的包有mysqldb  tornado  torndb,看你用的是pymysql还是mysqldb

2.1  普通安装  pip install

2.2 mysqldb 安装

安装mysqldb 之前需要配置mysql_config

sudo apt-get install libmysqlclient-dev

sudo apt-get install python-dev

然后安装。

3、启动错误

3.1 torndb的错误

if MySQLdb is not None:

# Fix the access conversions to properly recognize unicode/binary

FIELD_TYPE = MySQLdb.constants.FIELD_TYPE

FLAG = MySQLdb.constants.FLAG

CONVERSIONS = copy.copy(MySQLdb.converters.conversions)

field_types = [FIELD_TYPE.BLOB, FIELD_TYPE.STRING, FIELD_TYPE.VAR_STRING]

if 'VARCHAR' in vars(FIELD_TYPE):

field_types.append(FIELD_TYPE.VARCHAR)

#for field_type in field_types:

# CONVERSIONS[field_type] = [(FLAG.BINARY, str)] + CONVERSIONS[field_type]

注释掉这个

3.2 然后启动成功查询数据时可能还会原道这种错误。

https://www.cnblogs.com/simplezhuo/p/9811369.html

4、nginx 配置

4.1、tornado服务可以运行

python server.py --port 8888

nohup python server.py 登出也不会停止。

4.2、配置

default.conf

##

# You should look at the following URL's in order to grasp a solid understanding

# of Nginx configuration files in order to fully unleash the power of Nginx.

# http://wiki.nginx.org/Pitfalls

# http://wiki.nginx.org/QuickStart

# http://wiki.nginx.org/Configuration

#

# Generally, you will want to move this file somewhere, and start with a clean

# file but keep this around for reference. Or just disable in sites-enabled.

#

# Please see /usr/share/doc/nginx-doc/examples/ for more detailed examples.

##

# Default server configuration

#

upstream tornados{

server 127.0.0.1:8888;

}

proxy_next_upstream error;

server {

listen 80 default_server;

listen [::]:80 default_server;

# SSL configuration

#

# listen 443 ssl default_server;

# listen [::]:443 ssl default_server;

#

# Note: You should disable gzip for SSL traffic.

# See: https://bugs.debian.org/773332

#

# Read up on ssl_ciphers to ensure a secure configuration.

# See: https://bugs.debian.org/765782

#

# Self signed certs generated by the ssl-cert package

# Don't use them in a production server!#

# include snippets/snakeoil.conf;

# Add index.php to the list ifyou are using PHP

index index.html index.htm index.nginx-debian.html;

server_name111.231.201.164;

location/cnc/1/{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/2/{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/3{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/4{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/5{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/6{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/cnc/7{

alias/usr/web/cnc/;

index index.html index.htm;

}

location/api/{

allow111.231.201.164;

proxy_pass_header Server;

proxy_set_header Host $http_host;

proxy_redirect off;

proxy_set_header X-Real-IP $remote_addr;

proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

proxy_set_header X-Scheme $scheme;

proxy_pass http://127.0.0.1:8888/;

}

# pass the PHP scripts to FastCGI server listening on127.0.0.1:9000#

#location~\.php$ {

# include snippets/fastcgi-php.conf;

#

# # With php7.0-cgi alone:

# fastcgi_pass127.0.0.1:9000;

# # With php7.0-fpm:

# fastcgi_pass unix:/run/php/php7.0-fpm.sock;

#}

# deny access to .htaccess files,if Apache's document root

# concurs with nginx's one

#

#location~ /\.ht {

# deny all;

#}

}

# Virtual Host configurationforexample.com

#

# You can move that to a different file under sites-available/and symlink that

# to sites-enabled/to enable it.

#

#server {

# listen80;

# listen [::]:80;

#

# server_name example.com;

#

# root/var/www/example.com;

# index index.html;

#

# location/{

# try_files $uri $uri/ =404;

# }

#}

现在就是把tornado的服务127.0.0.1:8888 挂载在了80端口+api/上

5、supervisor 配置

5.1、安装supervisor

sudo apt-get install supervisor

创建配置文件echo_supervisord_conf > /etc/supervisord.conf

; Sample supervisor config file.

;

; For more information on the config file, please see:

; http://supervisord.org/configuration.html

;

; Notes:

; - Shell expansion ("~" or "$HOME") is not supported. Environment

; variables can be expanded using this syntax: "%(ENV_HOME)s".

; - Quotes around values are not supported, except in the case of

; the environment= options as shown below.

; - Comments must have a leading space: "a=b ;comment" not "a=b;comment".

; - Command will be truncated if it looks like a config file comment, e.g.

; "command=bash -c 'foo ; bar'" will truncate to "command=bash -c 'foo ".

;

; Warning:

; Paths throughout this example file use /tmp because it is available on most

; systems. You will likely need to change these to locations more appropriate

; for your system. Some systems periodically delete older files in /tmp.

; Notably, if the socket file defined in the [unix_http_server] section below

; is deleted, supervisorctl will be unable to connect to supervisord.

[unix_http_server]

file=/tmp/supervisor.sock ; the path to the socket file

;chmod=0700 ; socket file mode (default 0700)

;chown=nobody:nogroup ; socket file uid:gid owner

;username=user ; default is no username (open server)

;password=123 ; default is no password (open server)

; Security Warning:

; The inet HTTP server is not enabled by default. The inet HTTP server is

; enabled by uncommenting the [inet_http_server] section below. The inet

; HTTP server is intended for use within a trusted environment only. It

; should only be bound to localhost or only accessible from within an

; isolated, trusted network. The inet HTTP server does not support any

; form of encryption. The inet HTTP server does not use authentication

; by default (see the username= and password= options to add authentication).

; Never expose the inet HTTP server to the public internet.

;[inet_http_server] ; inet (TCP) server disabled by default

;port=127.0.0.1:9001 ; ip_address:port specifier, *:port for all iface

;username=user ; default is no username (open server)

;password=123 ; default is no password (open server)

[supervisord]

logfile=/tmp/supervisord.log ; main log file; default $CWD/supervisord.log

logfile_maxbytes=50MB ; max main logfile bytes b4 rotation; default 50MB

logfile_backups=10 ; # of main logfile backups; 0 means none, default 10

loglevel=info ; log level; default info; others: debug,warn,trace

pidfile=/tmp/supervisord.pid ; supervisord pidfile; default supervisord.pid

nodaemon=false ; start in foreground if true; default false

minfds=1024 ; min. avail startup file descriptors; default 1024

minprocs=200 ; min. avail process descriptors;default 200

;umask=022 ; process file creation umask; default 022

;user=supervisord ; setuid to this UNIX account at startup; recommended if root

;identifier=supervisor ; supervisord identifier, default is 'supervisor'

;directory=/tmp ; default is not to cd during start

;nocleanup=true ; don't clean up tempfiles at start; default false

;childlogdir=/tmp ; 'AUTO' child log dir, default $TEMP

;environment=KEY="value" ; key value pairs to add to environment

;strip_ansi=false ; strip ansi escape codes in logs; def. false

; The rpcinterface:supervisor section must remain in the config file for

; RPC (supervisorctl/web interface) to work. Additional interfaces may be

; added by defining them in separate [rpcinterface:x] sections.

[rpcinterface:supervisor]

supervisor.rpcinterface_factory = supervisor.rpcinterface:make_main_rpcinterface

; The supervisorctl section configures how supervisorctl will connect to

; supervisord. configure it match the settings in either the unix_http_server

; or inet_http_server section.

[supervisorctl]

serverurl=unix:///tmp/supervisor.sock ; use a unix:// URL for a unix socket

;serverurl=http://127.0.0.1:9001 ; use an http:// url to specify an inet socket

;username=chris ; should be same as in [*_http_server] if set

;password=123 ; should be same as in [*_http_server] if set

;prompt=mysupervisor ; cmd line prompt (default "supervisor")

;history_file=~/.sc_history ; use readline history if available

; The sample program section below shows all possible program subsection values.

; Create one or more 'real' program: sections to be able to control them under

; supervisor.

;[program:theprogramname]

;command=/bin/cat ; the program (relative uses PATH, can take args)

;process_name=%(program_name)s ; process_name expr (default %(program_name)s)

;numprocs=1 ; number of processes copies to start (def 1)

;directory=/tmp ; directory to cwd to before exec (def no cwd)

;umask=022 ; umask for process (default None)

;priority=999 ; the relative start priority (default 999)

;autostart=true ; start at supervisord start (default: true)

;startsecs=1 ; # of secs prog must stay up to be running (def. 1)

;startretries=3 ; max # of serial start failures when starting (default 3)

;autorestart=unexpected ; when to restart if exited after running (def: unexpected)

;exitcodes=0 ; 'expected' exit codes used with autorestart (default 0)

;stopsignal=QUIT ; signal used to kill process (default TERM)

;stopwaitsecs=10 ; max num secs to wait b4 SIGKILL (default 10)

;stopasgroup=false ; send stop signal to the UNIX process group (default false)

;killasgroup=false ; SIGKILL the UNIX process group (def false)

;user=chrism ; setuid to this UNIX account to run the program

;redirect_stderr=true ; redirect proc stderr to stdout (default false)

;stdout_logfile=/a/path ; stdout log path, NONE for none; default AUTO

;stdout_logfile_maxbytes=1MB ; max # logfile bytes b4 rotation (default 50MB)

;stdout_logfile_backups=10 ; # of stdout logfile backups (0 means none, default 10)

;stdout_capture_maxbytes=1MB ; number of bytes in 'capturemode' (default 0)

;stdout_events_enabled=false ; emit events on stdout writes (default false)

;stdout_syslog=false ; send stdout to syslog with process name (default false)

;stderr_logfile=/a/path ; stderr log path, NONE for none; default AUTO

;stderr_logfile_maxbytes=1MB ; max # logfile bytes b4 rotation (default 50MB)

;stderr_logfile_backups=10 ; # of stderr logfile backups (0 means none, default 10)

;stderr_capture_maxbytes=1MB ; number of bytes in 'capturemode' (default 0)

;stderr_events_enabled=false ; emit events on stderr writes (default false)

;stderr_syslog=false ; send stderr to syslog with process name (default false)

;environment=A="1",B="2" ; process environment additions (def no adds)

;serverurl=AUTO ; override serverurl computation (childutils)

; The sample eventlistener section below shows all possible eventlistener

; subsection values. Create one or more 'real' eventlistener: sections to be

; able to handle event notifications sent by supervisord.

;[eventlistener:theeventlistenername]

;command=/bin/eventlistener ; the program (relative uses PATH, can take args)

;process_name=%(program_name)s ; process_name expr (default %(program_name)s)

;numprocs=1 ; number of processes copies to start (def 1)

;events=EVENT ; event notif. types to subscribe to (req'd)

;buffer_size=10 ; event buffer queue size (default 10)

;directory=/tmp ; directory to cwd to before exec (def no cwd)

;umask=022 ; umask for process (default None)

;priority=-1 ; the relative start priority (default -1)

;autostart=true ; start at supervisord start (default: true)

;startsecs=1 ; # of secs prog must stay up to be running (def. 1)

;startretries=3 ; max # of serial start failures when starting (default 3)

;autorestart=unexpected ; autorestart if exited after running (def: unexpected)

;exitcodes=0 ; 'expected' exit codes used with autorestart (default 0)

;stopsignal=QUIT ; signal used to kill process (default TERM)

;stopwaitsecs=10 ; max num secs to wait b4 SIGKILL (default 10)

;stopasgroup=false ; send stop signal to the UNIX process group (default false)

;killasgroup=false ; SIGKILL the UNIX process group (def false)

;user=chrism ; setuid to this UNIX account to run the program

;redirect_stderr=false ; redirect_stderr=true is not allowed for eventlisteners

;stdout_logfile=/a/path ; stdout log path, NONE for none; default AUTO

;stdout_logfile_maxbytes=1MB ; max # logfile bytes b4 rotation (default 50MB)

;stdout_logfile_backups=10 ; # of stdout logfile backups (0 means none, default 10)

;stdout_events_enabled=false ; emit events on stdout writes (default false)

;stdout_syslog=false ; send stdout to syslog with process name (default false)

;stderr_logfile=/a/path ; stderr log path, NONE for none; default AUTO

;stderr_logfile_maxbytes=1MB ; max # logfile bytes b4 rotation (default 50MB)

;stderr_logfile_backups=10 ; # of stderr logfile backups (0 means none, default 10)

;stderr_events_enabled=false ; emit events on stderr writes (default false)

;stderr_syslog=false ; send stderr to syslog with process name (default false)

;environment=A="1",B="2" ; process environment additions

;serverurl=AUTO ; override serverurl computation (childutils)

; The sample group section below shows all possible group values. Create one

; or more 'real' group: sections to create "heterogeneous" process groups.

;[group:thegroupname]

;programs=progname1,progname2 ; each refers to 'x' in [program:x] definitions

;priority=999 ; the relative start priority (default 999)

; The [include] section can just contain the "files" setting. This

; setting can list multiple files (separated by whitespace or

; newlines). It can also contain wildcards. The filenames are

; interpreted as relative to this file. Included files *cannot*

; include files themselves.

[include]

files = /etc/supervisor/*.conf

再建一个配置文件

tornado.conf

[group:tornadoes]

programs=tornado-8888[program:tornado-8888]

command=/usr/bin/python /usr/web/tornadoTest/server.py --port=8888 ##python tornado启动py

directory=/usr/web/tornadoTest

user=root

autorestart=trueredirect_stderr=truestdout_logfile=/usr/web/tornadoTest/logs

loglevel=info

5.2 启动

启动 supervisord -c /etc/supervisord.conf  指定配置文件

supervisorctl shutdown  关闭supervisor

至此。

附上api的代码

server.py

#!/usr/bin/env python#-*- coding:utf-8 -*-

importtornado.ioloopfrom src.urls import * #引入urls

importtorndbimportconf.db as dbSettingsimportosclassApplication(tornado.web.Application):def __init__(self):

handlers=[#(r"/", MainHandler),

#(r"/story/(sishen[0-9]+)", StoryHandler), # 正则url映射,方便get

(r"/houses/([0-9]+)", HouseHandler),

(r"/houses", HouseHandler),

]

settings=dict(

template_path=os.path.join(os.path.dirname(__file__), "templates"),

static_path=os.path.join(os.path.dirname(__file__), "statics"),

debug=True,

)

super(Application, self).__init__(handlers, **settings)#获取数据库配置信息

dbInfo =dbSettings.default#创建一个全局mysql连接实例供handler使用

self.db = torndb.Connection(host=dbInfo['host'], user=dbInfo['user'],

password=dbInfo['password'], database=dbInfo['dbName'], charset='utf8')if __name__ == "__main__":

application=Application()

application.listen(8888)

tornado.ioloop.IOLoop.instance().start()

urls.py

importtornado.webimportjsonfrom conf.log import decoratore #引入日志装饰器

from conf.fun import *

classBaseHandler(tornado.web.RequestHandler):#blog.csdn.net/moshowgame 解决跨域问题

defset_default_headers(self):

self.set_header("Access-Control-Allow-Origin", "*") #这个地方可以写域名

self.set_header("Access-Control-Allow-Headers", "x-requested-with, Authorization")

self.set_header('Access-Control-Allow-Methods', 'POST, GET, OPTIONS')

self.set_header('Access-Control-Allow-Credentials', 'true')#def write(self, chunk):

#self.set_header('Access-Control-Allow-Origin', 'http://localhost:4200')

#self.set_header('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content-Type, Accept, x-token, X-File-Upload')

#self.set_header('Access-Control-Allow-Methods', 'POST, GET, PUT, OPTIONS, DELETE')

#self.set_header('Access-Control-Allow-Credentials', 'true')

#super(BaseHandler, self).write(chunk)

classMainHandler(BaseHandler):

@decoratoredefget(self):

self.write("Hello, World")#访问: http://localhost:8888/story/sishen232

#显示:U get story id is sishen232

classHouseHandler(BaseHandler):'''house class'''

def __init__(self, application, request):'''必填参数'''super().__init__(application, request)#预处理

self.data =ByteData(self.request.arguments)

self.params= ['title', 'position', 'size', 'address']

@decoratoredefpost(self):'''提交House接口'''

## 判断提交参数是否有误

#if(('title' not in raw_data) or ('position' not in raw_data)):

#self.write(json.dumps(

#{"false": {"msg": '参数错误'}}, ensure_ascii=False))

#return

code =paramsCheck(self.data, self.params)if code == 1:

raw_data=self.dataif('year' not inraw_data):

raw_data['year'] = ''

print(raw_data)

data=self.application.db.execute("insert into house(title, position, size, address, year) values('{}', '{}', {}, '{}', '{}')".format(raw_data['title'], raw_data['position'], float(raw_data['size']), raw_data['address'], raw_data['year']))#self.write(json.dumps({"sum": s}))

self.write(json.dumps(

{"success": {"msg": '添加成功'}}, ensure_ascii=False))else:

self.write(json.dumps(

{"false": {"msg": '参数错误'}}, ensure_ascii=False))def get(self, House_id=''):'''# 获取House接口

# House_id 存在则获取该条数据,不存在获取所有数据'''sql= 'select * from house' if House_id == '' else 'select * from house where id = {id}'.format(

id=House_id)

data=self.application.db.query(sql)#self.write(json.dumps({"sum": s}))

self.write(json.dumps(

{"success": {"msg": '获取成功', "data": data}}, ensure_ascii=False))

日志装饰器和一些通用函数去掉即可。


版权声明:本文为weixin_39593061原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。