Python,App Engine:HTTP 多部分 POST 到 Vk.Ads API

Python, App Engine: HTTP multipart POST to Vk.Ads API

几天来,我试图自己解决这个问题,搜索示例和文档,也 it wasn't solved on ruSO。所以,我希望可以在 enSO 上找到解决方案。

我使用 Python 和 Google App Engine 在 Vk 社交网络上开发了自动创建广告的服务。最初,广告图片加载到我的服务器(第 1 部分),然后它们在某个时间上传到 Vk 服务器(第 2.1 和 2.2 部分 ).似乎图片已正确加载并存储在我的服务器上(我下载了它们并与原始图片进行了比较——每个字节都是相同的)。但为了以防万一,我附上了 第 1 部分 代码。

要上传图片到Vk.Ads首先我需要to get a URL — this is simple, so skip it. Secondly, I need to send a POST request to this link with field file with binary content of the photo (API documentation)。我为此创建了两种方式(2.1 和 2.2),但它们都是 returns errcode: 2,这意味着 corrupted file。在我看来,问题是关于请求的,但我不排除它在我的服务器上文件 uploading/storage 的可能性,或者 API 的一些奇怪的工作。我将不胜感激任何答案和评论。

1。上传到我的服务器

import webapp2
from google.appengine.ext import ndb

# stores pictures on the server
class Photo(ndb.Model):
    name = ndb.StringProperty()
    img = ndb.BlobProperty()

    @staticmethod
    def get(name):
        retval = Photo.query(Photo.name == name).get()
        return retval

    @staticmethod
    def create(name, blob):
        retval = Photo()
        retval.name = name
        retval.img = blob
        return retval

class PhotosPage(webapp2.RequestHandler):
    def get(self):
        # general content of the page:
        html = '''<form action="/photos" method="post" enctype="multipart/form-data">
            <input type="file" name="flimg"/>
            <input value="new_pic" name="flname"/>
            <input type="submit" value="Upload"/> </form>'''

    def post(self):
        n = str(self.request.get('flname'))
        f = self.request.get('flimg')
        p = Photo.get(n)
        if p:
            p.img = f
        else:
            p = Photo.create(n, f)
        p.put()

2.1。 POST 到 API,方法 #1,使用 urlfetch и poster:

from poster.encode import multipart_encode, MultipartParam
from google.appengine.api import urlfetch

name = 'file'
content = ... # file binary content
where = ... # gotten URL

options = {
    'file': MultipartParam(
        name=name,
        value=content,
        filename=name,
        filetype='image/png',
        filesize=len(content))
}

data, headers = multipart_encode(options)
pocket = "".join(data)

result = urlfetch.fetch(
    url=where,
    payload=pocket,
    method=urlfetch.POST,
    headers=headers)

2.2。 POST 到 API,方法 #2,使用 requests:

import requests

name = 'file'
content = ... # file binary content
where = ... # gotten URL

# I also tried without this dict; is it necessary?
data = {
    'fileName': name,
    'fileSize': len(content),
    'description': 'undefined',
}

result = requests.post(where, files={name: StringIO(content)}, data=data)

此外,对于第二种方法,我提取了我的请求内容:

POST
https://pu.vk.com/c.../upload.php?act=ads_add&mid=...&size=m&rdsn=1&hash_time=...&hash=...&rhash=...&api=1

Content-Length: 15946
Content-Type: multipart/form-data; boundary=b4b260eace4e4a7082a99753b74cf51f

--b4b260eace4e4a7082a99753b74cf51f
Content-Disposition: form-data; name="description"
undefined

--b4b260eace4e4a7082a99753b74cf51f
Content-Disposition: form-data; name="fileSize"
15518

--b4b260eace4e4a7082a99753b74cf51f
Content-Disposition: form-data; name="fileName"
file

--b4b260eace4e4a7082a99753b74cf51f
Content-Disposition: form-data; name="file"; filename="file" 
< File binary content >

--b4b260eace4e4a7082a99753b74cf51f-- 

更新。

感谢 SwiftStudier,我找到了问题的根源:StringIOBytesIO 与文件 open 的行为不同.如果我只使用 open 代码运行良好,但它不适用于虚拟文件。如何解决?

import requests
from io import BytesIO

with open('path.to/file.png', 'rb') as fin:
    content = BytesIO(fin.read())

token = '...'
url = 'https://api.vk.com/method/ads.getUploadURL?access_token=' + token + '&ad_format=2'
upload_url = requests.get(url).json()['response']

post_fields = {
    'access_token': token
}

data_fields = {
    # This works:
    # 'file': open('path.to/file.png', 'rb')

    # But this does not:
    'file': content
}

response = requests.post(upload_url, data=post_fields, files=data_fields)
print(response.text)

不确定是否有帮助,但我会 post 无论如何

我用 requests 上传了一张图片到 ads

import requests

token = '***'
url = f'https://api.vk.com/method/ads.getUploadURL?access_token={token}&ad_format=1' # I set add_format randomly just to avoid an error of this parameter was missing
upload_url = requests.get(url).json()['response']

post_fields = {
    'access_token': token
}

data_fields = {
    'file': open('/path/to/image.png', 'rb')
}

response = requests.post(upload_url, data=post_fields, files=data_fields)
print(response.text)

结果看起来像是有效的照片上传,收到的数据可用于广告 API 的进一步操作。

经过大量实验和调查不同的 HTTP 请求内容后,我发现了错误代码和工作代码之间的唯一区别。它只有大约 4 个字节:文件名必须包含扩展名。 Vk API 甚至忽略 Content-Type: image/png,但需要 .png 或类似的文件名。所以,这行不通:

requests.post(upload_url, files={
    'file': BytesIO('<binary file content>')
})

但是这个选项可以正常工作:

requests.post(upload_url, files={
    'file': ('file.png', BytesIO('<binary file content>'), 'image/png')
})

就像这个一样,它不适用于 GAE:

requests.post(upload_url, files={
    'file': open('/path/to/image.png', 'rb')
})

StringIOStringIO 都适合该任务。如前所述,Content-Type 并不重要,它可以只是 multipart/form-data.