Bottle:タグのアーカイブ｜ネットマーベラス㈱

Python3 Bottleフレームワーク入門（その１０）- WSGI via uwsgi Server on SSL

2018年5月27日Python Bottle Framework, トピックス, ノウハウ

投稿者：担当者

今回は、Pythonでお馴染みのWSGI（外部サーバ）の技術を使ったSSL接続を試してみます。

WSGIとはシンプルすぎて非常にわかりにくいものですが、簡単に言うと通常コマンドラインで標準出力しているものを内部及び外部のhttpサーバで使われているネットワークの土管にバイパスしてブラウザへの表示を拝借してしまおうという発想です。

bottleフレームワークはもとからWSGIの内部WEBサーバを走らせる機能が標準装備しているため外部WEBサーバ使う理由に何が必要なのか？という疑問を持つ人もいると思います。それはbottleの標準WEBサーバはシングルスレッドなので多くの接続を処理したり、SSL接続をしたい場合はこのようにWSGIの外部サーバ連携する技術を駆使しないと現実的なWEBサーバとして利用できないのです。ではまず最初にbottleで簡単なWEBサーバを起動してみましょう。

from bottle import route, run, template,default_app
from bottle import TEMPLATE_PATH

@route('/')
def index():
    return "Hello World! Bottle Simple Web Server!"

if __name__ == '__main__':
    run(host='0.0.0.0', port=80)

from bottle import route, run, template,default_app

from bottle import TEMPLATE_PATH

@route('/')

def index():

return "Hello World! Bottle Simple Web Server!"

if __name__ == '__main__':

run(host='0.0.0.0', port=80)

index.pyを実行するとシンプルなWEBサーバ(正確に言うとシングルスレッド内部WSGIサーバです。)が起動します。

# python index.py

1	# python index.py

ここまでは誰でも普段からやっていると思います。

今度はこれを外部接続WSGI仕様に変えてソースを改良します。
特にWSGI関連ライブラリーを呼び出す必要はありません。ポイントはapplicationというクラスです。uWSGIから呼び出すため、mainは生成されずelseへ分岐します。ここへbottleのインスタンスを渡してあげます。このケースではdefault_app()ですが、もしご自分でbottleのインスタンスを他の変数やクラスへ継承させているならそれを代入しましょう。これがWSGI仕様にする要になります。

from bottle import route, run, template,default_app
from bottle import TEMPLATE_PATH

@route('/')
def index():
    return "Hello World! Bottle and uWSGI!"

if __name__ == '__main__':
    run(host='0.0.0.0', port=80)
else:
    application = default_app()

from bottle import route, run, template,default_app

from bottle import TEMPLATE_PATH

@route('/')

def index():

return "Hello World! Bottle and uWSGI!"

if __name__ == '__main__':

run(host='0.0.0.0', port=80)

else:

application = default_app()

最下行にたった２行が追加されました。たったこれだけです。大変シンプルですね。

次はuwsgiというシンプルな外部WSGI接続が可能なWEBサーバーをpipでインストールします。

# pip3 install uwsgi
# uwsgi --http 0.0.0.0:8080 --wsgi-file index.py

1 2	# pip3 install uwsgi # uwsgi --http 0.0.0.0:8080 --wsgi-file index.py

これでブラウザへ接続をすれば「Hello World! Bottle and uWSGI!」と表示されます。

次にwsgiでSSL接続を行ってみましょう。pythonのプログラムは特に修正する必要はありません。uwsgiのネットワークトンネルを拝借していますから、SSLの処理はuwsgiの機能で行います。

テスト環境でSSLサーバの設置を行う場合のやり方

よくオレオレ証明書を使う方がいますが、今は安いSSL証明書なら年間ライセンス1000円程度で購入できます。私はテスト用に1000円のSSLライセンスを購入して実験利用しています。
テスト環境で実験する場合はWindows側では”c:\Windows\System32\Drivers\etc\hosts”を管理者権限モードでテキストエディタで開いてDNSの照合よりも先にhostsファイルに登録したドメインとIPアドレスを参照するように予めテスト用のドメインを登録しておきます。ドメイン認証だけのSSLならこれでうまくいきます。それ以外の認証が入っている高価なSSLだと「安全ではない」がでるかもしれません。

こうすることで、SSL証明書のドメインとテスト用のサーバのドメインを一致させブラウザを騙します。そうしないとhttps接続時に赤色でバツや三角がブラウザ上のURLそばのアイコンが表示されます。

証明書の準備と取得証明書のマージ処理からサーバ起動まで

証明書が購入できたら次に作業するフォルダーに証明書用のフォルダーを作成します。今はとりあえずauthという名前のフォルダーを作成します。そこに購入した証明書ファイルを配置します。以下のような最低でも３種類のファイルが必要となります。

サーバー証明書(server.crt)
サーバ秘密鍵(server.key)
中間証明書(ca-bundle.ca)

これらのファイルで中間証明書はuwsgiコマンドのパラメータで指定する事ができないため、中間証明書とサーバ証明書は１つのファイルにマージします。

# cat server.crt ca-bundle.ca > integrated.crt

1	# cat server.crt ca-bundle.ca > integrated.crt

マージされた証明書は必ず一度エディターで中を開けてチェックして下さい。順番は関係あります。サーバ証明書が一番上に来るようにして下さい。また中間証明書はサーバ証明書のend区切りコメントに連続にならないように改行を必ず入れてください。そうしないとエラーになります。

下記は証明書を結合した場合の証明書同士のボーダーを示しています。予め結合する前にサーバ証明書に改行を入れておくと安全です。必ず結合後はチェックしましょう。

次のようにuwsgiを起動する際に鍵ファイルや証明書を指定します。

# uwsgi --master --https 0.0.0.0:443,auth/integrated.crt,auth/server.key,HIGH   --wsgi-file index.py

1	# uwsgi --master --https 0.0.0.0:443,auth/integrated.crt,auth/server.key,HIGH --wsgi-file index.py

実際の実行時のターミナル画面は次のようになります。

実際に本番稼働させる場合は実行用のユーザとグループを用意してchrootさせて実行すると以下の警告はなくなります。

その他uwsgiの実行オプションはここ

パラメータでスレッド数、プロセス数やパフォーマンスに関するその他の項目、ログの場所など細かくチューニングが可能です

スレッド数やプロセス数を増やせば必ずしもマルチスレッドに対応したコンテンツになるとは限りません。例えばコンテンツがREAD主体の静的コンテンツはスレッド数やプロセス数を増やせばマルチスレッドになると思いますが、動的に変化するコンテンツは内部側でもマルチスレッド対応(thread_safeは必須)にしないと駄目なケースが多いと思います。というか、多くのケースはPythonコンテンツ側もマルチスレッド動作に対応する必然性があるかもしれません。マルチスレッド対応とは２種類の意味があります。DBなどファイル書き込みが複数のスレッドで競合が起きないようにするという意味と複数のコネクションを１プロセスで捌くという意味です。今回の場合はスクリプト起動なので必要最低限で前者が必須のケースです。マルチスレッド通信はProxyタイプ通信で連携する場合では必須なので他の章を参考にしてください。

[root@localhost wsgi]# uwsgi --master --https 0.0.0.0:443,auth/server.crt,auth/server.key,HIGH   --wsgi-file index.py
*** Starting uWSGI 2.0.17 (64bit) on [Sun May 27 19:50:58 2018] ***
compiled with version: 4.8.5 20150623 (Red Hat 4.8.5-28) on 27 May 2018 07:45:36
os: Linux-3.10.0-862.2.3.el7.x86_64 #1 SMP Wed May 9 18:05:47 UTC 2018
nodename: localhost.localdomain
machine: x86_64
clock source: unix
pcre jit disabled
detected number of CPU cores: 1
current working directory: /root/works/wsgi
detected binary path: /usr/local/bin/uwsgi
uWSGI running as root, you can use --uid/--gid/--chroot options
*** WARNING: you are running uWSGI as root !!! (use the --uid flag) *** 
your processes number limit is 7232
your memory page size is 4096 bytes
detected max file descriptor number: 1024
lock engine: pthread robust mutexes
thunder lock: disabled (you can enable it with --thunder-lock)
uWSGI http bound on 0.0.0.0:443 fd 4
uwsgi socket 0 bound to TCP address 127.0.0.1:45638 (port auto-assigned) fd 3
uWSGI running as root, you can use --uid/--gid/--chroot options
*** WARNING: you are running uWSGI as root !!! (use the --uid flag) *** 
Python version: 3.5.2 (default, May 26 2018, 18:31:29)  [GCC 4.8.5 20150623 (Red Hat 4.8.5-28)]
*** Python threads support is disabled. You can enable it with --enable-threads ***
Python main interpreter initialized at 0x1df5120
uWSGI running as root, you can use --uid/--gid/--chroot options
*** WARNING: you are running uWSGI as root !!! (use the --uid flag) *** 
your server socket listen backlog is limited to 100 connections
your mercy for graceful operations on workers is 60 seconds
mapped 145840 bytes (142 KB) for 1 cores
*** Operational MODE: single process ***
WSGI app 0 (mountpoint='') ready in 0 seconds on interpreter 0x1df5120 pid: 27627 (default app)
uWSGI running as root, you can use --uid/--gid/--chroot options
*** WARNING: you are running uWSGI as root !!! (use the --uid flag) *** 
*** uWSGI is running in multiple interpreter mode ***
spawned uWSGI master process (pid: 27627)
spawned uWSGI worker 1 (pid: 27628, cores: 1)
spawned uWSGI http 1 (pid: 27629)

[root@localhost wsgi]# uwsgi --master --https 0.0.0.0:443,auth/server.crt,auth/server.key,HIGH --wsgi-file index.py

*** Starting uWSGI 2.0.17 (64bit) on [Sun May 27 19:50:58 2018] ***

compiled with version: 4.8.5 20150623 (Red Hat 4.8.5-28) on 27 May 2018 07:45:36

os: Linux-3.10.0-862.2.3.el7.x86_64 #1 SMP Wed May 9 18:05:47 UTC 2018

nodename: localhost.localdomain

machine: x86_64

clock source: unix

pcre jit disabled

detected number of CPU cores: 1

current working directory: /root/works/wsgi

detected binary path: /usr/local/bin/uwsgi

uWSGI running as root, you can use --uid/--gid/--chroot options

*** WARNING: you are running uWSGI as root !!! (use the --uid flag) ***

your processes number limit is 7232

your memory page size is 4096 bytes

detected max file descriptor number: 1024

lock engine: pthread robust mutexes

thunder lock: disabled (you can enable it with --thunder-lock)

uWSGI http bound on 0.0.0.0:443 fd 4

uwsgi socket 0 bound to TCP address 127.0.0.1:45638 (port auto-assigned) fd 3

uWSGI running as root, you can use --uid/--gid/--chroot options

*** WARNING: you are running uWSGI as root !!! (use the --uid flag) ***

Python version: 3.5.2 (default, May 26 2018, 18:31:29) [GCC 4.8.5 20150623 (Red Hat 4.8.5-28)]

*** Python threads support is disabled. You can enable it with --enable-threads ***

Python main interpreter initialized at 0x1df5120

uWSGI running as root, you can use --uid/--gid/--chroot options

*** WARNING: you are running uWSGI as root !!! (use the --uid flag) ***

your server socket listen backlog is limited to 100 connections

your mercy for graceful operations on workers is 60 seconds

mapped 145840 bytes (142 KB) for 1 cores

*** Operational MODE: single process ***

WSGI app 0 (mountpoint='') ready in 0 seconds on interpreter 0x1df5120 pid: 27627 (default app)

uWSGI running as root, you can use --uid/--gid/--chroot options

*** WARNING: you are running uWSGI as root !!! (use the --uid flag) ***

*** uWSGI is running in multiple interpreter mode ***

spawned uWSGI master process (pid: 27627)

spawned uWSGI worker 1 (pid: 27628, cores: 1)

spawned uWSGI http 1 (pid: 27629)

ブラウザから以下のようにアクセスができたら成功です。中間証明書がきちんと登録ができていないと今のブラウザは厳しいので「このサイトは安全でない」と表示されるので要注意です。必ず中間証明書とサーバー証明書をマージして区切り線が前後に改行されていることを確認しましょう。

Python Bottle Framework入門全１３回: 1.基礎編サーバ起動; 2.リクエストメソッド; 3.ORM Peewee (MySQL); 4.ORM Peewee CRUD; 5.Cookie And Session; 6.Abort and Redirect; 7.マルチスレッドWEBサーバ; 8.デーモン化; 9.Json; 10.WSGI on SSL; 11.Apache連携起動(外部WSGI) SSL接続; 12.Apache連携起動(ReverseProxy)SSL接続; 13.hprox連携起動(ReverseProxy)SSL接続&HTTP2対応

合わせて読みたいPython MySQL操作関連

タグ: Bottle, Python, SSL, uwsgi, WSGI, フレームワーク

Python3 Bottleフレームワーク入門（その９）- Json

2017年8月28日Python Bottle Framework, トピックス

投稿者：担当者

Bottleに限ったjsonの返却の仕方という訳ではないが、特定URLを叩いた時のjson返却方法を試してみる。REST APIのようなものを作る時の基礎として掲載する。

from bottle import Bottle,route,abort,template
import simplejson as json

app = Bottle()

tasks = [
          {
             'id': 1,
             'title': u'Buy groceries',
             'description': u'Milk, Cheese, Pizza, Fruit, Tylenol',
             'done': False
          },
          {
             'id': 2,
             'title': u'Learn Python',
             'description': u'Need to find a good Python tutorial on the web',
             'done': False
          }
         ]

@app.route('/api/v1.0/tasks', methods=['GET'])
def get_tasks():
        return json.dumps({'tasks': tasks})

@app.route('/json/<uid>/<collection>/<group>/<items:path>')
def add(uid, collection, group, items):
    return json.dumps({'uid':uid, 'collection':collection, 'group':group,'items':items})

if __name__ == '__main__':
     app.run(host="0.0.0.0",port="8080",debug=True)

from bottle import Bottle,route,abort,template

import simplejson as json

app = Bottle()

tasks = [

{

'id': 1,

'title': u'Buy groceries',

'description': u'Milk, Cheese, Pizza, Fruit, Tylenol',

'done': False

{

'id': 2,

'title': u'Learn Python',

'description': u'Need to find a good Python tutorial on the web',

'done': False

}

]

@app.route('/api/v1.0/tasks', methods=['GET'])

def get_tasks():

return json.dumps({'tasks': tasks})

@app.route('/json/<uid>/<collection>/<group>/<items:path>')

def add(uid, collection, group, items):

return json.dumps({'uid':uid, 'collection':collection, 'group':group,'items':items})

if __name__ == '__main__':

app.run(host="0.0.0.0",port="8080",debug=True)

※http://xxx.xxx.xxx.xxx/api/v1.0/tasks で実験。

※http://xxx.xxx.xxx.xxx/json/1/2/3/pathfindで実験。

合わせて読みたいJson記事

FORM入力をJSONでサーバへ送出する仕組みの基本的な例（Vue.jsを使った場合）

Python Bottle Framework入門全１３回: 1.基礎編サーバ起動; 2.リクエストメソッド; 3.ORM Peewee (MySQL); 4.ORM Peewee CRUD; 5.Cookie And Session; 6.Abort and Redirect; 7.マルチスレッドWEBサーバ; 8.デーモン化; 9.Json; 10.WSGI on SSL; 11.Apache連携起動(外部WSGI) SSL接続; 12.Apache連携起動(ReverseProxy)SSL接続; 13.hprox連携起動(ReverseProxy)SSL接続&HTTP2対応

合わせて読みたいPython MySQL操作関連

タグ: Bottle, Json, Python, フレームワーク

Python3 Bottleフレームワーク入門（その８）- デーモン化

2017年8月26日Python Bottle Framework, トピックス

投稿者：担当者

Bottleはコマンドラインで起動すると終了でCTRL+Cを入れるまでコマンドプロンプトが戻ってきません。これでは不便と考えるなら自前でデーモン化してみましょう。最近ではBottleDaemonというモジュールもありますがオリジナルで色々開発しているとそのままではBottleDaemonが使えないケースが多いです。そんなときは自前でデーモン化処理を作ってしまいましょう。それほど難しいものではありません。

from bottle import Bottle,template,abort
import os,sys,time

app = Bottle()

@app.route('/hello/<name>')
def index(name):
       return template('<b>Hello {{name}}</b>!', name=name)

def daemon_serv():
    pid = os.fork()
    try:
       if pid != 0:
          fd = open('./serv.pid','w')
          fd.write(str(pid) + '\n')
          fd.close()
          sys.exit()

    except OSError as e:
       sys.stderr.write("BottleFork: Failed: %d (%s)\n" % (e.errno, e.strerror))
       sys.exit(1)

    while 1:
    　　app.run(server='paste',host="0.0.0.0",port='8080')


if __name__ == "__main__":
          daemon_serv()

from bottle import Bottle,template,abort

import os,sys,time

app = Bottle()

@app.route('/hello/<name>')

def index(name):

return template('<b>Hello {{name}}</b>!', name=name)

def daemon_serv():

pid = os.fork()

try:

if pid != 0:

fd = open('./serv.pid','w')

fd.write(str(pid) + '\n')

fd.close()

sys.exit()

except OSError as e:

sys.stderr.write("BottleFork: Failed: %d (%s)\n" % (e.errno, e.strerror))

sys.exit(1)

while 1:

　　app.run(server='paste',host="0.0.0.0",port='8080')

if __name__ == "__main__":

daemon_serv()

◯　デーモンの起動と停止

$ start-serv
$ stop-serv

1 2	$ start-serv $ stop-serv

◯　起動プログラム

#!/bin/sh
ps -e|grep python
if [ $? -eq 1 ]; then
   python mthread.py 2> /dev/null
else
   echo "Serverを停止させてください"
fi

#!/bin/sh

ps -e|grep python

if [ $? -eq 1 ]; then

python mthread.py 2> /dev/null

else

echo "Serverを停止させてください"

◯　停止プログラム

#!/bin/sh

kill -9 `cat ./serv.pid`

case $? in
    0)
       rm ./serv.pid ;;
    1)
       echo "プロセスを正しく終了できませんでした。"
       exit 1 ;;
esac

exit 0

#!/bin/sh

kill -9 `cat ./serv.pid`

case $? in

rm ./serv.pid ;;

echo "プロセスを正しく終了できませんでした。"

exit 1 ;;

esac

exit 0

Python Bottle Framework入門全１３回: 1.基礎編サーバ起動; 2.リクエストメソッド; 3.ORM Peewee (MySQL); 4.ORM Peewee CRUD; 5.Cookie And Session; 6.Abort and Redirect; 7.マルチスレッドWEBサーバ; 8.デーモン化; 9.Json; 10.WSGI on SSL; 11.Apache連携起動(外部WSGI) SSL接続; 12.Apache連携起動(ReverseProxy)SSL接続; 13.hprox連携起動(ReverseProxy)SSL接続&HTTP2対応

合わせて読みたいPython MySQL操作関連

タグ: Bottle, Python, デーモン化, フレームワーク

Python3 Bottleフレームワーク入門（その７）- マルチスレッドWEBサーバ(Paste,Rocket)

2017年8月25日Python Bottle Framework, トピックス

投稿者：担当者

今回の記事ではBottleのWEBサーバについて解説していきたいと思います。Bottleの標準で用意されているWEBサーバはシングルスレッドのWSGIサーバ(wsgirefサーバ)です。Bottleに限らずほとんどの様々な言語のフレームワークはテスト用にシングルスレッドのWEBサーバが用意されています。あくまでも開発中に作ったものを確認するために用意されたものです。しかし、マルチスレッドでもう少し挙動を確認したい場合もあるはずです。やはりシングルとマルチではプログラムの作り方が根本的に違います。また、pythonで作ったWEBサーバに関してセキュリティ攻撃や機能的に心もとないと思うならリバースプロキシーWEBサーバでApache連携すれば良いですが、その場合はPythonコンテンツ側はマルチスレッドである必要があります。故にマルチスレッドでの動作ができる内部連携するWSGI WEBサーバをご紹介したいと思います。

マルチスレッドpasteモジュール

Bottleをマルチスレッドで動作させるモジュールは色々ありますが古くからあり使いやすいのがpasteモジュールです。今回はpasteモジュールのインプリメントを見ていきましょう。
※2023/03/8 にPasteWebサーバの設定方法を刷新しました。ログ出力も対応しています。画面とファィルに出力されます。後半のRocketServerは既に古くてpython3.6以前でないと動作しないと思います。

pasteモジュールの導入

まず最初にpasteモジュールを導入します。

$ pip3 install paste
$ pip3 install mako

1 2	$ pip3 install paste $ pip3 install mako

簡単なマルチスレッド起動のコーディングを書く

makoテンプレートエンジンを使っていますので、テンプレートはPython3 Bottleフレームワーク入門（その１）で紹介しているものをそのまま使ってください。

import sys
import logging
from bottle import mako_view as view
from bottle import Bottle, route, PasteServer, request

app = Bottle()

# ログの設定
logger = logging.getLogger('access_logger')
logger.setLevel(logging.INFO)

# ログフォーマットの設定
formatter = logging.Formatter('%(asctime)s - %(levelname)s - Accessed: %(url)s - User-Agent: %(user_agent)s')

# ログファイルへのハンドラを追加
file_handler = logging.FileHandler('access.log')
file_handler.setLevel(logging.INFO)
file_handler.setFormatter(formatter)
logger.addHandler(file_handler)

# アクセスログを出力するためのデコレータ関数
def log_access(func):
    def wrapper(*args, **kwargs):
        logger.info('', extra={'url': request.url, 'user_agent': request.headers.get('User-Agent')})
        return func(*args, **kwargs)
    return wrapper

@app.route('/hello/:names')
@view('hello')
@log_access
def index(names):
    return {'name': names}

if __name__ == "__main__":
    app.run(server=PasteServer, host="0.0.0.0", port='8000', daemon_threads=True, threadpool_workers=10,use_threadpool=True)

import sys

import logging

from bottle import mako_view as view

from bottle import Bottle, route, PasteServer, request

app = Bottle()

# ログの設定

logger = logging.getLogger('access_logger')

logger.setLevel(logging.INFO)

# ログフォーマットの設定

formatter = logging.Formatter('%(asctime)s - %(levelname)s - Accessed: %(url)s - User-Agent: %(user_agent)s')

# ログファイルへのハンドラを追加

file_handler = logging.FileHandler('access.log')

file_handler.setLevel(logging.INFO)

file_handler.setFormatter(formatter)

logger.addHandler(file_handler)

# アクセスログを出力するためのデコレータ関数

def log_access(func):

def wrapper(*args, **kwargs):

logger.info('', extra={'url': request.url, 'user_agent': request.headers.get('User-Agent')})

return func(*args, **kwargs)

return wrapper

@app.route('/hello/:names')

@view('hello')

@log_access

def index(names):

return {'name': names}

if __name__ == "__main__":

app.run(server=PasteServer, host="0.0.0.0", port='8000', daemon_threads=True, threadpool_workers=10,use_threadpool=True)

負荷テスト

nperfを使って負荷テストをしてみましょう。-cが並行スレッド数で-nがテストの回数です。

◯　nperfのインストール

$ sudo npm install -g http-perf

1	$ sudo npm install -g http-perf

$ nperf -c10 -n 60 http://localhost:8080/hello/tanaka
[status] response# /request_id time: client time (ms) (server time (ms))
[200] 1 /0 time: 59 (-1)
[200] 2 /1 time: 10 (-1)
[200] 3 /2 time: 6 (-1)
[200] 4 /3 time: 5 (-1)
[200] 5 /4 time: 5 (-1)
[200] 6 /5 time: 5 (-1)
[200] 7 /6 time: 5 (-1)
[200] 8 /7 time: 5 (-1)
[200] 9 /8 time: 5 (-1)
[200] 10 /9 time: 5 (-1)
[200] 11 /10 time: 5 (-1)
[200] 12 /11 time: 5 (-1)
[200] 13 /12 time: 5 (-1)
[200] 14 /13 time: 6 (-1)
[200] 15 /14 time: 5 (-1)
[200] 16 /15 time: 5 (-1)
[200] 17 /16 time: 5 (-1)
[200] 18 /17 time: 5 (-1)
[200] 19 /18 time: 5 (-1)
[200] 20 /19 time: 5 (-1)
[200] 21 /20 time: 5 (-1)
[200] 22 /21 time: 5 (-1)
[200] 23 /22 time: 5 (-1)
[200] 24 /23 time: 5 (-1)
[200] 25 /24 time: 5 (-1)
[200] 26 /25 time: 5 (-1)
[200] 27 /26 time: 5 (-1)
[200] 28 /27 time: 5 (-1)
[200] 29 /28 time: 6 (-1)
[200] 30 /29 time: 5 (-1)
[200] 31 /30 time: 5 (-1)
[200] 32 /31 time: 6 (-1)
[200] 33 /32 time: 5 (-1)
[200] 34 /33 time: 5 (-1)
[200] 35 /34 time: 6 (-1)
[200] 36 /35 time: 5 (-1)
[200] 37 /36 time: 5 (-1)
[200] 38 /37 time: 5 (-1)
[200] 39 /38 time: 6 (-1)
[200] 40 /39 time: 10 (-1)
[200] 41 /40 time: 5 (-1)
[200] 42 /41 time: 5 (-1)
[200] 43 /42 time: 5 (-1)
[200] 44 /43 time: 5 (-1)
[200] 45 /44 time: 5 (-1)
[200] 46 /45 time: 5 (-1)
[200] 47 /46 time: 5 (-1)
[200] 48 /47 time: 5 (-1)
[200] 49 /48 time: 5 (-1)
[200] 50 /49 time: 5 (-1)
[200] 51 /50 time: 5 (-1)
[200] 52 /51 time: 5 (-1)
[200] 53 /52 time: 5 (-1)
[200] 54 /53 time: 5 (-1)
[200] 55 /54 time: 5 (-1)
[200] 56 /55 time: 5 (-1)
[200] 57 /56 time: 5 (-1)
[200] 58 /57 time: 5 (-1)
[200] 59 /58 time: 5 (-1)
[200] 60 /59 time: 6 (-1)
stats:
{ statuses: { '200': 60 },
  min: 5,
  max: 59,
  avg: 6.183333333333334,
  count: 60,
  rate: 143.88489208633092,
  start: 1532730411094,
  total_time: 417 }

$ nperf -c10 -n 60 http://localhost:8080/hello/tanaka

[status] response# /request_id time: client time (ms) (server time (ms))

[200] 1 /0 time: 59 (-1)

[200] 2 /1 time: 10 (-1)

[200] 3 /2 time: 6 (-1)

[200] 4 /3 time: 5 (-1)

[200] 5 /4 time: 5 (-1)

[200] 6 /5 time: 5 (-1)

[200] 7 /6 time: 5 (-1)

[200] 8 /7 time: 5 (-1)

[200] 9 /8 time: 5 (-1)

[200] 10 /9 time: 5 (-1)

[200] 11 /10 time: 5 (-1)

[200] 12 /11 time: 5 (-1)

[200] 13 /12 time: 5 (-1)

[200] 14 /13 time: 6 (-1)

[200] 15 /14 time: 5 (-1)

[200] 16 /15 time: 5 (-1)

[200] 17 /16 time: 5 (-1)

[200] 18 /17 time: 5 (-1)

[200] 19 /18 time: 5 (-1)

[200] 20 /19 time: 5 (-1)

[200] 21 /20 time: 5 (-1)

[200] 22 /21 time: 5 (-1)

[200] 23 /22 time: 5 (-1)

[200] 24 /23 time: 5 (-1)

[200] 25 /24 time: 5 (-1)

[200] 26 /25 time: 5 (-1)

[200] 27 /26 time: 5 (-1)

[200] 28 /27 time: 5 (-1)

[200] 29 /28 time: 6 (-1)

[200] 30 /29 time: 5 (-1)

[200] 31 /30 time: 5 (-1)

[200] 32 /31 time: 6 (-1)

[200] 33 /32 time: 5 (-1)

[200] 34 /33 time: 5 (-1)

[200] 35 /34 time: 6 (-1)

[200] 36 /35 time: 5 (-1)

[200] 37 /36 time: 5 (-1)

[200] 38 /37 time: 5 (-1)

[200] 39 /38 time: 6 (-1)

[200] 40 /39 time: 10 (-1)

[200] 41 /40 time: 5 (-1)

[200] 42 /41 time: 5 (-1)

[200] 43 /42 time: 5 (-1)

[200] 44 /43 time: 5 (-1)

[200] 45 /44 time: 5 (-1)

[200] 46 /45 time: 5 (-1)

[200] 47 /46 time: 5 (-1)

[200] 48 /47 time: 5 (-1)

[200] 49 /48 time: 5 (-1)

[200] 50 /49 time: 5 (-1)

[200] 51 /50 time: 5 (-1)

[200] 52 /51 time: 5 (-1)

[200] 53 /52 time: 5 (-1)

[200] 54 /53 time: 5 (-1)

[200] 55 /54 time: 5 (-1)

[200] 56 /55 time: 5 (-1)

[200] 57 /56 time: 5 (-1)

[200] 58 /57 time: 5 (-1)

[200] 59 /58 time: 5 (-1)

[200] 60 /59 time: 6 (-1)

stats:

{ statuses: { '200': 60 },

min: 5,

max: 59,

avg: 6.183333333333334,

count: 60,

rate: 143.88489208633092,

start: 1532730411094,

total_time: 417 }

Rocketを使ったマルチスレッド対応

最近使った感じではこちらのRocketの方がpasteより良い感じ。pasteはPython2.7からPython3.xの対応が中途半端でエラーを吐くことがあるのでメンテがいまいち。Rocketも最新バージョンがバグがありエラーとなるのでpipから導入したものは起動エラーが生じ動作に至りませんでした。まともに動くForkしたバージョン(1.2.4)で利用すると良いです。

Rocketサーバのインストールとロギング機能の設置

$ git clone https://github.com/errbotio/rocket.git
$ cd rocket
$ sudo python3 setup.py install
$ sudo pip3 install wsgi-request-logger

$ git clone https://github.com/errbotio/rocket.git

$ cd rocket

$ sudo python3 setup.py install

$ sudo pip3 install wsgi-request-logger

Rocketを使ったマルチスレッドサーバ(server.py)のソースコード

ログ出力の機能を加えました。Apacheのログ形式で実行ディレクトリ上のrocket.logに吐き出されます。
ちなみにport番号の後にサーバ証明書、プライベート鍵を記述するとHTTPS対応になりますので是非トライしてみてください。
Apacheサーバでリバースプロキシー連携するならSSLはApache側に持たせたほうが絶対に良いです。理由は細かいSSLオプション関連の制御ができるからです。

from rocket import Rocket
from bottle import Bottle,template
from requestlogger import WSGILogger, ApacheFormatter
from logging.handlers import TimedRotatingFileHandler

app=Bottle()

@app.route('/hello/< uname >')
def index(uname):
      return template('<b>Hello {{ var_name }}</b>!', var_name=uname)

web_handlers = [ TimedRotatingFileHandler('rocket.log', 'd', 7) , ]
app_logfix = WSGILogger(app, web_handlers, ApacheFormatter())

app_info = dict(wsgi_app=app_logfix,future=True)
#server = Rocket(interfaces=[('0.0.0.0', 9043,'/etc/pki/org/serv.pem','/etc/pki/org/priv.pem')],method='wsgi',app_info=app_info,min_threads=3,max_threads=13,timeout=300)
server = Rocket(interfaces=[('0.0.0.0', 8080)],method='wsgi',app_info=app_info,min_threads=3,max_threads=13,timeout=300)
server.start()

from rocket import Rocket

from bottle import Bottle,template

from requestlogger import WSGILogger, ApacheFormatter

from logging.handlers import TimedRotatingFileHandler

app=Bottle()

@app.route('/hello/< uname >')

def index(uname):

return template('<b>Hello {{ var_name }}</b>!', var_name=uname)

web_handlers = [ TimedRotatingFileHandler('rocket.log', 'd', 7) , ]

app_logfix = WSGILogger(app, web_handlers, ApacheFormatter())

app_info = dict(wsgi_app=app_logfix,future=True)

#server = Rocket(interfaces=[('0.0.0.0', 9043,'/etc/pki/org/serv.pem','/etc/pki/org/priv.pem')],method='wsgi',app_info=app_info,min_threads=3,max_threads=13,timeout=300)

server = Rocket(interfaces=[('0.0.0.0', 8080)],method='wsgi',app_info=app_info,min_threads=3,max_threads=13,timeout=300)

server.start()

サーバの実行

$ python3 server.py

1	$ python3 server.py

Python Bottle Framework入門全１３回: 1.基礎編サーバ起動; 2.リクエストメソッド; 3.ORM Peewee (MySQL); 4.ORM Peewee CRUD; 5.Cookie And Session; 6.Abort and Redirect; 7.マルチスレッドWEBサーバ; 8.デーモン化; 9.Json; 10.WSGI on SSL; 11.Apache連携起動(外部WSGI) SSL接続; 12.Apache連携起動(ReverseProxy)SSL接続; 13.hprox連携起動(ReverseProxy)SSL接続&HTTP2対応

合わせて読みたいPython MySQL操作関連

タグ: Bottle, Python, フレームワーク, マルチスレッド

Python3 Bottleフレームワーク入門（その６）- Abort and Redirect

2017年8月25日Python Bottle Framework, トピックス

投稿者：担当者

本記事ではアボート処理とリダイレクトについて説明する。abortの出番はWEB上のコンテンツを作る上では重要である。よくあるのはアクセス禁止、ファイルが存在しないケースだろう。特に後者はCMSの世界ではソフトウェア404を使うケースが多い。でもグーグルがソフトウェア404だと正しく認識してくれないため検索インデックスに該当ファイルが無いという認識が持てず古いインデックスを更新しません。結果的に悪い評価になってしまうことがあります。このような場合はabort関数を使用してハードウェア404を返してあげるとベターです。

アボート処理

アボート処理はWEB上で異常を示すエラーコードと共に使用するものです。

from bottle import route, abort
@route('/404')
def 404error():
    abort(404, "File not Found.")

from bottle import route, abort

@route('/404')

def 404error():

abort(404, "File not Found.")

リダイレクト処理

リダイレクト処理は何らかの理由があって、最初のURLから別のURLへ転送します。

from bottle import redirect
@route('/wrong/url')
def wrong():
    redirect("/right/url")

from bottle import redirect

@route('/wrong/url')

def wrong():

redirect("/right/url")

※この２つの関数redirect(),abort()は必ず実行するとException Errorを起こしますが気にする必要はありません。使うと発生するそのようなものと解釈してください。元々そのような仕様で作られています。つまり何らかの異常を示す際に使う関数であるからと理解するとわかり易いかもしれません。エラーを抑制したい場合はBottleのconfigでcatchallをFalseに設定することで止めることができます。

Python Bottle Framework入門全１３回: 1.基礎編サーバ起動; 2.リクエストメソッド; 3.ORM Peewee (MySQL); 4.ORM Peewee CRUD; 5.Cookie And Session; 6.Abort and Redirect; 7.マルチスレッドWEBサーバ; 8.デーモン化; 9.Json; 10.WSGI on SSL; 11.Apache連携起動(外部WSGI) SSL接続; 12.Apache連携起動(ReverseProxy)SSL接続; 13.hprox連携起動(ReverseProxy)SSL接続&HTTP2対応

合わせて読みたいPython MySQL操作関連

タグ: abort, Bottle, Python, redirect, 例外処理必ず発生

Python3 Bottleフレームワーク入門（その１０）- WSGI via uwsgi Server on SSL

Python3 Bottleフレームワーク入門（その１０）- WSGI via uwsgi Server on SSL

テスト環境でSSLサーバの設置を行う場合のやり方

証明書の準備と取得証明書のマージ処理からサーバ起動まで

合わせて読みたいPython MySQL操作関連

Python3 Bottleフレームワーク入門（その９）- Json

合わせて読みたいJson記事

合わせて読みたいPython MySQL操作関連

Python3 Bottleフレームワーク入門（その８）- デーモン化

合わせて読みたいPython MySQL操作関連

Python3 Bottleフレームワーク入門（その７）- マルチスレッドWEBサーバ(Paste,Rocket)

マルチスレッドpasteモジュール

pasteモジュールの導入

簡単なマルチスレッド起動のコーディングを書く

負荷テスト

Rocketを使ったマルチスレッド対応

Rocketサーバのインストールとロギング機能の設置

Rocketを使ったマルチスレッドサーバ(server.py)のソースコード

サーバの実行

合わせて読みたいPython MySQL操作関連

Python3 Bottleフレームワーク入門（その６）- Abort and Redirect

アボート処理

リダイレクト処理

合わせて読みたいPython MySQL操作関連

Tags

本日の記事Rating(毎日PM0:00リセット)

人気の記事（総合）

人気(Python/Security)記事