1

Python から BlobStore に BLOB をアップロードしようとしていますが、https://...appspot.comとhttps://...com/では機能しますが、http からまったく同じコードを実行すると機能しません。 BlobStore は 500 エラーを返します。

そうでない場合でも、接続を常に安全にしようとしました。

これが私のコードです：

@staticmethod
def save_to_blobstore(_request, id, file_contents, file_type, file_name = 'fixmeh.png'):
    upload_url  = blobstore.create_upload_url('/upload-item/blob-key/{}'.format(id))

    if upload_url.startswith('http://') and 'localhost.com' not in _request.get_host():
        upload_url = 'https' + upload_url[4:]

    # ----- CREATING FORMDATA -----
    boundary = 'WebKitFormBoundaryE19zNvXGzXaLvS5C'
    body = '\r\n'.join([
        '--' + boundary,
        'Content-Disposition: form-data; name="file"; filename="{}"'.format(file_name),
        'Content-Type: {}'.format(file_type),
        '',
        file_contents,
        '',
        '--' + boundary + '--',
        '',
    ])

    headers = {
        'Content-Type'  : 'multipart/form-data; boundary={}'.format(boundary),
        'User-Agent'    : 'Mozilla/5.0 (X11; Linux x86_64; rv:31.0) Gecko/20100101 Firefox/31.0',
    }

    logging.critical('blobstore save')

    # TODO Why the hell do we receive deadline limit exceeded?
    request = urllib2.Request(upload_url)

    # ----- FORCING SECURE CONNECTION EXCEPT ON LOCALHOST -----
    if 'localhost.com' in _request.get_host():
        conn = httplib.HTTPConnection(request.get_host(), timeout = 50)
    else:
        conn = httplib.HTTPSConnection(request.get_host(), timeout = 50)

    conn._follow_redirects = True

    logging.info(['upload_url', upload_url ])
    logging.info(['get_host', request.get_host() ])
    logging.info(['get_selector', request.get_selector() ])
    conn.request('POST', request.get_selector(), body, headers)

    try:
        response = conn.getresponse()
        response_body = response.read()

        logging.info(response_body)

        # TODO we need to have an exception if the response is not 200
    except DeadlineExceededError:
        logging.exception('Saving blob - DeadlineExceededError')
    except:
        logging.exception('Saving blob')

HTTP 経由で実行すると、これは BlobStore から返されますが、あまり役に立ちません。https://console.developers.google.com/project/.../logsまたは他の場所にブロブストア エラーを記録する方法はありますか。

<html><head>
<meta http-equiv="content-type" content="text/html;charset=utf-8">
<title>500 Server Error</title></head>
<body text=#000000 bgcolor=#ffffff>
<h1>Error: Server Error</h1>
<h2>The server encountered an error and could not complete your request.
<p>Please retry your last submission.</p>
<p>If the problem persists, please contact the person responsible for the application you're using, or, if you are that person,
<a href="http://code.google.com/appengine/community.html">report</a> your
problem and mention this error message and the query that caused it.</h2>
</body></html>

が http では機能しないのに https では機能する理由を教えてください。(SDK では http で動作することに注意してください - そこには ssl はありません。これは appspot でのみ発生します)

4

2 に答える 2

0

指示と迅速な対応に感謝します。私はあなたのコードからいくつかのアイデアを取り、私のものを微調整しました。

私は本当に google.appengine.api.urlfetch を使用したくありませんでした。悲しいことに、現時点では実験する時間がありません。

万一何かに遭遇した場合に備えて、最終的なコードを次に示します (voscausa の URL「App Engine update blob」も参照してください:

    back_url = '{}{}/upload-item/blob-key/{}'.format(_request.protocol, _request.get_host(), id)
    # logging.info(back_url)

    upload_url  = blobstore.create_upload_url(back_url)

    BNDR = b'WebKitFormBoundaryE19zNvXGzXaLvS5C'  # '--PythonBlobstorevarBoundaryVXGzXaLvS5C'
    CRLF = b'\r\n'
    DD   = b'--'

    body = b''.join([
        DD + BNDR + CRLF,
        b'Content-Disposition: form-data; name="file"; filename="{}"'.format(file_name) + CRLF,
        b'Content-Type: {}'.format(file_type) + CRLF,
        CRLF,
        file_contents + CRLF,
        DD + BNDR + DD + CRLF,
    ])

    headers = {
        b'Content-Type' : b'multipart/form-data; boundary={}'.format(BNDR),
        # b'User-Agent' : b'Mozilla/5.0 (X11; Linux x86_64; rv:31.0) Gecko/20100101 Firefox/31.0',
    }

    try:
        response = urlfetch.fetch(
            url                 = upload_url,
            payload             = body,
            method              = urlfetch.POST,
            deadline            = 40,
            follow_redirects    = False,
            headers             = headers
        )

        if response.status_code == 200:
            logging.info(response.content)
        else:
            logging.info(response)
            logging.error(response.content)
            logging.exception('URL : {} fetch ERROR : {}'.format(upload_url, response.status_code))
    except (urlfetch.DownloadError, DeadlineExceededError), e:
        logging.exception('fetch {} download or deadline error, exception : {}'.format(upload_url, str(e)))
于 2015-09-14T15:41:11.270 に答える