从Twisted上传到GCS

Question

我需要把文件从一个扭曲的应用程序放到Google的云存储中。

我一直在使用亚马逊和txAWS，但现在我正在使用GCS，我不确定是否有什么东西可以让我这样做？

可以在GCS中使用txAWS吗？这听起来像是一个奇怪的问题，但是在GCS中使用boto的S3Connection是可能的，所以也许有一种方法可以在txAWS中做同样的事情。

Answer 1

我建议在GCS JSON API中使用Twisted Web client。下面是一个列出存储桶内容的示例：

import json
from twisted.internet import reactor
from twisted.internet.defer import Deferred
from twisted.internet.protocol import Protocol
from twisted.web.client import Agent
from twisted.web.error import Error
from twisted.web.http_headers import Headers

GCS_BASE_URL = 'https://www.googleapis.com/storage/v1beta1'
GCS_API_KEY = '<your-api-key>'
GCS_BUCKET = '<your-bucket>'

class ResponseAccumulate(Protocol):
    def __init__(self, finished):
        self.finished = finished
        self.fullbuffer = ''

    def dataReceived(self, bytes):
        print 'Received %d bytes.' % len(bytes)
        self.fullbuffer += bytes

    def connectionLost(self, reason):
        if isinstance(reason, Error):
            print 'Finished receiving body:', reason.getErrorMessage()
        else:
            parsed = json.loads(self.fullbuffer)
            print 'Bucket contents:'
            for item in parsed['items']:
              print ' ', item['id']
        self.finished.callback(None)

agent = Agent(reactor)

d = agent.request(
    'GET',
    '%s/b/%s/o?key=%s' % (GCS_BASE_URL, GCS_BUCKET, GCS_API_KEY),
    Headers({'User-Agent': ['Twisted Web Client Example']}),
    None)

def cbResponse(response):
    print 'Response received', response.code
    finished = Deferred()
    response.deliverBody(ResponseAccumulate(finished))
    return finished
d.addCallback(cbResponse)

def cbShutdown(ignored):
    reactor.stop()
d.addBoth(cbShutdown)

reactor.run()