如何操作谷歌应用引擎数据存储中的文件答案

【问题标题】：How to manipulate files in google app engine datastore如何操作谷歌应用引擎数据存储中的文件
【发布时间】：2011-09-07 15:39:20
【问题描述】：

我的问题围绕着用户将文本文件上传到我的应用程序。在将其保存到数据存储之前，我需要获取此文件并使用我的应用程序对其进行处理。从我读过的一点点来看，我了解到用户上传的内容作为 blob 直接进入数据存储区，如果我可以获取该文件，对其执行操作（意味着更改内部数据）然后将其重新写回数据存储。所有这些操作都需要由应用程序完成。不幸的是，来自数据存储文档，http://code.google.com/appengine/docs/python/blobstore/overview.html 应用程序无法直接在数据存储区中创建 Blob。这是我的主要头痛。我只需要一种从我的应用程序在数据存储区中创建新 blob/文件的方法，而无需任何用户上传交互。

【问题讨论】：

见code.google.com/appengine/docs/python/blobstore/…；您现在可以使用 files API 以编程方式写入 blobstore。（注意：这是在同一页上说您不能以编程方式创建 blob；对于保持文档最新的这么多：））

标签： google-app-engine file google-cloud-datastore uploading

【解决方案1】：

blobstore != datastore。

只要在您的实体上使用db.BlobProperty，您的数据小于 1MB，您就可以在 datastore 中读取和写入数据。

作为 Wooble cmets，新的 File API 允许您写入 blobstore，但除非您使用任务或类似 mapreduce 库的东西逐渐写入 blobstore 文件，否则您仍然受到限制读取/写入的 1MB API 调用限制。

【讨论】：

此外，如果您明确使用 blobstore 进行上传，用户上传内容只会直接转到 blobstore - 否则它们会像任何其他形式一样发送到您的应用程序。

【解决方案2】：

感谢您的帮助。经过许多不眠之夜、3 部 App Engine 书籍和大量谷歌搜索，我找到了答案。这是代码（应该很容易解释）：

from __future__ import with_statement
from google.appengine.api import files
from google.appengine.ext import blobstore
from google.appengine.ext import webapp
from google.appengine.ext.webapp import util

class MainHandler(webapp.RequestHandler):
    def get(self):
        self.response.out.write('Hello WOrld')
        form=''' <form action="/" method="POST" enctype="multipart/form-data">
Upload File:<input type="file" name="file"><br/>
<input type="submit"></form>'''
        self.response.out.write(form)
        blob_key="w0MC_7MnZ6DyZFvGjgdgrg=="
        blob_info=blobstore.BlobInfo.get(blob_key)
        start=0
        end=blobstore.MAX_BLOB_FETCH_SIZE-1
        read_content=blobstore.fetch_data(blob_key, start, end)
        self.response.out.write(read_content)
    def post(self):
        self.response.out.write('Posting...')
        content=self.request.get('file')
        #self.response.out.write(content)
        #print content
        file_name=files.blobstore.create(mime_type='application/octet-stream')
        with files.open(file_name, 'a') as f:
            f.write(content)
        files.finalize(file_name)
        blob_key=files.blobstore.get_blob_key(file_name)
        print "Blob Key="
        print blob_key

def main():
    application=webapp.WSGIApplication([('/', MainHandler)],debug=True)
    util.run_wsgi_app(application)

if __name__=='__main__':
    main()

【讨论】：