如何保存上传的文件，然后用 GAE 返回？

Question

我需要使用 GAE 创建以下应用程序：

1. 用户上传了一些文件（比如说 POST 到 myapp.appspot.com/upload）；
2. 我需要保存它（在数据存储中？）并返回链接；
3. 根据提供的链接，用户应该能够在接下来的 5 分钟内下载文件。

我创建了以下内容：

app.yaml

application: synoext
version: 1
runtime: python
api_version: 1

handlers:
- url: /upload
  script: synoext.py

- url: /file/\w+
  script: synoext.py

- url: /cleanup
  script: synoext.py

synoext.py

import datetime
import logging
import urlparse

from google.appengine.ext import webapp
from google.appengine.ext.webapp.util import run_wsgi_app
from google.appengine.ext import db
from google.appengine.api import urlfetch

class Files(db.Model):
    file = db.BlobProperty()
    added = db.DateTimeProperty(auto_now_add=True)  

class UploadFile(webapp.RequestHandler):
    def post(self):
        logging.info('(POST) Uploading new file')
        # saving file in the database
        file = Files()
        file.file = db.Blob(self.request.get("file"))
        file.put()

        self.response.out.write('http://myapp.appspot.com/' + str(file.key()))

class GetFile(webapp.RequestHandler):
    def get(self, key):
        file = db.get(key)
        if file is not None:
            self.response.headers['Content-Type'] = 'application/x-bittorrent'
            self.response.out.write(file.file)
        else:
            self.response.set_status(404)

class Cleanup(webapp.RequestHandler):
    def get(self):
        '''Automatically run job (cron) to delete old records (maximum 10000)
        from Files database (records, which are older than 5 minutes)
        '''
        fiveMinutesAgoDate = datetime.datetime.now() - datetime.timedelta(minutes=5)

        q = db.GqlQuery("SELECT * FROM Files WHERE added < :1", fiveMinutesAgoDate)
        results = q.fetch(10000)
        db.delete(results)

        self.response.out.write('{"result": true}')


application = webapp.WSGIApplication(
                                     [('/upload', UploadFile),
                                      ('/file/(\w+)', GetFile),
                                      ('/cleanup', Cleanup)],
                                     debug=True)

def main():
    run_wsgi_app(application)

if __name__ == "__main__":
    main()

正确吗？方法是否正确？或者，我不应该使用数据存储吗？

更新。奇怪，但是下面的代码

def get(self, key):
    file = db.get(key)
    if file is not None:

如果使用了不正确的密钥，则无法正常工作。 这里有什么问题？

Answer 1

粗略查看一下代码，您的方法应该可行。但是，您可能希望使用 Blobstore 而不是数据存储中的 blob，具体取决于您的需求和您尝试提供的文件的大小。

Answer 2

由于存储的文件非常小，您绝对应该像您正确的那样使用datastore。

一些建议：

1. 由于您只需要删除键，因此您应该只查询带有SELECT __key__ FROM Files WHERE .. 的键，从而节省一些资源。

2. 如果文件数量很大，您可以使用mapper-api 删除所有条目；您可以使用 control api 从您的代码中启动 mapreduce 作业。

3. /file/(\w+) 无法捕获 url applications、_ 和 - 的每个 base64 编码键都是有效字符，您也应该将它们与类似 /file/([\w_-]+) 的内容匹配