Python의 Tornado 프레임워크는 데이터베이스에 대한 비동기 비차단 액세스를 구현합니다.

tornado는 http 비차단 서버를 사용하기 위해 tornado 프레임워크, mongodb 데이터베이스 및 모터(mongodb의 비동기 드라이버)를 사용하여 간단히 tornado의 비차단 기능을 구현하겠습니다.

다른 환경에서도 다운로드 및 설치 가능

1. mongodb 설치

$ sudo apt-get install update
$ sudo apt-get install mongodb

2. 모터 설치

$ pip install motor

논블로킹

# conf.py

import os
import motor
from handlers import index, auth

BASE_DIR = os.path.join(__file__)

handlers = [
  (r'^/$', index.IndexHandler),
  (r'^/auth/register$', auth.RegisterHandler),
  (r'^/auth/login$', auth.LoginHandler),
]

settings = dict(
  debug = True,
  template_path = os.path.join(BASE_DIR, 'templates'),
  static_path = os.path.join(BASE_DIR, 'static'),
)

client = motor.MotorClient("127.0.0.1")
db = client.meet

먼저 구성 파일에서 데이터베이스에 연결합니다. client.db_name의 db_name은 데이터베이스 이름입니다

 # handlers/__init__.py
class BaseHandler(tornado.web.RequestHandler, TemplateRendering):
  def initialite(self):
    ...

  @property
  def db(self):
    return self.application.db

db( ) 속성 장식을 사용하고 속성처럼 데이터베이스에 액세스합니다.

# auth.py

import os 
import time 
import tornado.web
from tornado import gen
from . import BaseHandler

class RegisterHandler(BaseHandler):
  def get(self):
    self.render_html('register.html')

  @tornado.web.asynchronous
  @gen.coroutine
  def post(self):
    username = self.get_argument('username', None)
    email = self.get_argument('email', None)
    password = self.get_argument('password', None)

    data = {
      'username': username,
      'email': email,
      'password': password,
      'timestamp': time.time() * 1000,
    }

    if username and email:
      yield self.db.user.insert(data)
    self.redirect('/')

class LoginHandler(BaseHandler):
  
  @tornado.web.asynchronous
  @gen.coroutine
  def get(self):
    username = self.get_argument('useranme')
    user = yield self.db.user.find_one({'username': username})
    self.render_html('login.html', user=user)

@gen.coroutine 장식은 함수를 차단하지 않고 사용하는 대신 생성기를 반환합니다. 콜백 함수. 모터 비동기도 항복을 통해 구현됩니다(그렇지 않으면 콜백 함수가 반환되어야 함). 사실 이 예제는 시간이 너무 짧다는 점을 반영하지 않습니다.
수정해 보겠습니다. code

# 之前
yield self.db.user.insert(data)

# 之后
yield tornado.gen.Task(tornado.ioloop.IOLoop.instance().add_timeout, time.time() + 10)

여기에서 애플리케이션은 time.sleep의 비차단 구현인 tornado.ioloop.IOloop.instance().add_timeout을 통해 차단됩니다. 여기서 time.sleep을 사용하면 tornado가 단일 스레드이므로 전체 애플리케이션이 차단되므로 다른 핸들러도 액세스할 수 없습니다.
등록 페이지에서 등록한 후 /auth/login을 클릭한 것을 볼 수 있습니다. 차단 기간 동안 로그인 페이지에 직접 접속하여 비차단 처리를 완료했습니다.

비동기 리디렉션 문제
토네이도 사용 시 자주 발생하는 문제에 대해 적어보겠습니다. 문제 및 해결책 (의심스러운 점에 대해 답변해 주신 pythonistas에게 감사의 말씀을 전하고 싶습니다)

1. 문제

웹에 등록된 사용자 기능을 구현하고 싶습니다. 프레임워크가 tornado 데이터베이스와 mongodb를 사용하지만 등록 중에 예외 리디렉션 오류가 발생합니다. 이제 코드를 붙여넣으세요.

class Register(BaseHandler):
  def get(self):
    self.render_html('register.html')

  @tornado.web.aynchronous
  @gen.coroutine
  def post(self):
    username = self.get_argument('username')
    email = self.get_argument('email')
    password = self.get_argument('password')
    captcha = self.get_argument('captcha')

    _verify_username = yield self.db.user.find_one({'username': username})
    if _verify_username:
      self.flash(u'用户名已存在', 'error')
      self.redirect('/auth/register')

    _verify_email = yield self.db.user.find_one({'email': email})
    if _verify_email:
      self.flash(u'邮箱已注册', 'error')
      self.redirect('/auth/register')

    if captcha and captcha == self.get_secure_cookie('captcha').replace(' ',''):
      self.flash(u'验证码输入正确', 'info')
    else:
      self.flash(u'验证码输入错误', 'error')
      self.redirect('/auth/register')

    password = haslib.md5(password + self.settings['site']).hexdigest()

    profile = {'headimg': '', 'site': '', 'job': '', 'signature':'',
          'github': '', 'description': ''}
    user_profile = yield self.db.profile.insert(profile)
    user = {'username': username, 'email': email, 'password': password,
        'timestamp': time.time(), 'profile_id': str(user_profile)}

    yield self.db.user.insert(user)
    self.set_secure_cookie('user', username)
    self.redirect('/')

사용자가 등록 페이지로 이동하고 싶었습니다. 인증코드를 잘못 입력했는데 문제는 인증코드가 틀리면 계속 코드가 실행된다는 점입니다. self.redirect.finish 이후에 self를 추가해도 코드가 종료되는데 이미 self.finish가 있기 때문입니다. self.redirect 기능을 실행하면 비정상종료를 알리는 코드가 두 번 나옵니다.
위의 이유로 코드는 종료되지 않으며, 인증코드가 틀리더라도 사용자는 계속 등록하게 됩니다.

2. 해결책

return self.redirect('/auth/register')

또는

self.redirect('/auth/register')
return

( 1) Segmentdefault
self.finish에서 열성적인 사용자 rsj217이 제공한 답변은 @tornado.web.aynchronous가 토네이도에게 요청(긴 링크)을 기다릴 것이라고 알려주기 때문에 요청을 해제합니다.

(2) Segmentdefault
self.finish에서 열정적인 사용자 Evian이 제공한 답변은 물론 함수에서 벗어나지 않습니다. 그렇지 않으면 원하는 대로 할 수 있습니다. 요청이 완료된 후 해야 할 일.

3. 요약

위의 문제는 self.finish를 점프아웃 기능으로 잘못 간주했기 때문에 발생했습니다

self.redirect는 점프를 위해 request.headers에 위치를 설정합니다

self.finish는 요청을 끄지만 함수에서 벗어나지는 않습니다

추가 Python의 Tornado 프레임워크 데이터베이스 관련 기사에 대한 비동기 비차단 액세스를 구현합니다. PHP 중국어 웹사이트에 주목하세요!