tornado文件上载被阻止

Question

我正在尝试创建一个文件上传服务与龙卷风。在

但我注意到，当多个用户上传文件时，tornado会等待第一个用户完成并处理下一个。在

在Tornado上进行异步文件上载的正确方法是什么？在

我的职位：

  @tornado.web.asynchronous
  def post(self):
    list_of_img = ['png','jpg','jpeg','gif']
    list_of_files = ['rtf','txt','ppt','pptx','doc','docx','pdf','xls','xlsx','rar','zip','tgz','bz','gz','tar','bz2','3gp','mp4','m15','avi','mp3']
    path  =  __UPLOADS__
    try:
      fileinfo = self.request.files['file'][0]
      filebody = fileinfo['body']
      filename = fileinfo['filename']
      filetype = fileinfo['content_type']
      extn     = os.path.splitext(filename)[1]

      n_filename = str(uuid.uuid4()) + extn

      # rcv file
      print "saving", n_filename + "..."
      output_file = open(n_filename, 'w')
      output_file.write(filebody)

      # upload to s3
      print "uploading", n_filename + "..."

      self.upload(path, n_filename)

      # clean up
      print "cleaning", n_filename + "..."
      self.delete_local(n_filename)

      self.finish(n_filename)
    except KeyError, key:
      delete = self.get_argument("delete", None, True)
      if delete:
        filename = self.get_argument("filename", None, True)

        print "deleting", filename + "..."
        self.delete(path, filename)

        self.finish(filename)

Answer 1

Gevent（Greenlets）是解决阻塞部分的免费午餐方式。在

^{1}$

但要小心，有时会弄坏东西。在

Answer 2

应该使用@asynchronous修饰符来标记已经异步的方法；它不会使方法异步。这个post方法是同步的，因为它在将控制权返回IOLoop之前完成它要做的所有事情。您需要使upload()方法异步（这通常意味着它要么接受回调参数，要么返回一个Future），然后在不阻止post()的情况下调用它（我建议使用@gen.coroutine修饰符，并通过生成它们返回的Futures调用慢速操作）。在