Python 和 pushbullet api: 发送文件

Python and pushbullet api: send a file

我正在尝试使用 Pushbullet 按照他们的 API docs 发送文件。 这是我的功能:

def push_file(AccessToken, file_name):
    f = open(file_name, 'rb')
    file_type = mimetypes.guess_type(file_name)[0]

    print("Uploading {0}...".format(file_name))
    try:
        data = {
            'file_name': file_name, 
            'file_type' : file_type
        }

        resp = requests.post(UPLOAD_REQUEST_URL, data=data, auth=(AccessToken, '')).json()
        if resp.get('error') != None:
            print("Error: {0}".format(resp.get('error')['message']))
            return

        file_url = resp.get('file_url')
        print(file_url)
        resp = requests.post(resp.get('upload_url'), data=resp.get('data'), auth=(AccessToken, ''), files={'file': f})

        data = { 
            'type' : 'file', 
            'file_name' : file_name, 
            'file_type' : file_type, 
            'file_url' : file_url, 
            'body' : ''
        }
        resp = requests.post(PUSH_URL, data=data, auth=(AccessToken, '')).json()


    except requests.exceptions.ConnectionError:
        traceback.print_exc()
    f.close()

但我不断收到:

requests.exceptions.ConnectionError: HTTPSConnectionPool(host='s3.amazonaws.com', port=443): Max retries exceeded with url: /pushbullet-uploads (Caused by <class 'ConnectionResetError'>: [Errno 104] Connection reset by peer)

如果我使用另一个 AccessToken,我仍然会收到此错误,即使这是我第一次 post url。

根据 Pusbullet API

All POST requests should be over HTTPS and use a JSON body with the Content-Type header set to "application/json".

尝试像这样更改您的 requests.post 调用:

resp = requests.post(UPLOAD_REQUEST_URL, json=data, auth=(AccessToken, '')).json()

使用 json=data 而不是 data=data。请求会自动将 Content-Type 设置为 application/json

不幸的是,上传过程不是很好,希望尽快改进。这是一个不遵守 JSON 规则的请求。有一个 curl 示例可以说明这一点 (https://docs.pushbullet.com/#upload-request),但理解 curl 语法基本上是不可能的。

这是我刚刚输入的一个示例,它似乎有效:

import requests
import json

ACCESS_TOKEN = '<your access token here>'
resp = requests.post('https://api.pushbullet.com/v2/upload-request', data=json.dumps({'file_name': 'image.jpg'}), headers={'Authorization': 'Bearer ' + ACCESS_TOKEN, 'Content-Type': 'application/json'})
if resp.status_code != 200:
    raise Exception('failed to request upload')
r = resp.json()
resp = requests.post(r['upload_url'], data=r['data'], files={'file': open('image.jpg', 'rb')})
if resp.status_code != 204:
    raise Exception('failed to upload file')
print r['file_name'], r['file_type'], r['file_url']