阿里菜鳥物流雲API調用--python

工作需要寫一個程序調用菜鳥物流雲五級地址查詢api，此處決定用python實現。

 

 

 

 

調用實例如圖：

 

 

接口文檔：

 

先申請獲得appkey與resourceid：

需要查詢的數據集：

 

讀取文件存入一個list：

def get_address():
    try:
        with open(os.getcwd() + r'\address.txt', 'r') as f:
            address = f.readlines()
        return address
    except:
        print('打開文件失敗')
        return ''

 

 

構造請求參數：

def get_raw_input(address):
    raw_input = {
        "address": address,
        "limit": "20"
    }
    return raw_input

 

 

構造公共請求參數：

def get_param(sign, content):
    param = {
        'msg_type': 'CNDZK_ADDRESS_QUERY',
        'data_digest': sign,
        'logistic_provider_id': 'd0119848ab......e1df5d8d6dc149',
        'logistics_interface': content
    }
    return param

 

 

計算請求簽名（MD5值算法與base64編碼）：

def get_data_digest(inputs, keys):
    m1 = hashlib.md5()
    m1.update((inputs + keys).encode('utf-8'))

    # base64.b64encode(m1.hexdigest()) 得到錯誤值!!!
    return base64.b64encode(m1.digest())

此處踩到幾個坑卡了很久，主要是m1.hexdigest()與m1.digest()的不同，導致計算出的結果與java，js算出的不同

一開始以為是str轉bytes的問題，注意python的str.encode('utf-8')與java的getBytes()結果在顯示上有所不同（前者返回bytes類型，后者返回byte[]類型）

 

 

請求調用api並寫入文件：

address_list = get_address()

for x in address_list:
    # unicode形態轉中文，去掉空格（否則查不出）
    inputs = json.dumps(get_raw_input(x)).encode('utf-8').decode('unicode_escape').replace(' ', '')

    result = requests.post(url, data=get_param(get_data_digest(inputs, keys), inputs), headers=headers)
    result = result.content.decode(encoding='utf-8')
    # print(result)
    results = results + result + '\r\n'


try:
    with open(os.getcwd()+r'\result.txt', 'w') as f:
        f.write(results)
        print("寫入成功")
except:
    print("寫文件失敗")

 此處又踩到一個小坑-。-，由於python3.x的str類型中文數據默認采用unicode編碼顯示，所以會得到中文變成\u...的數據，導致查詢失敗

json.dumps()將dict轉化為json字符串返回，先utf-8編碼為bytes類型

再用decode('unicode_escape')解碼讓中文字符正常顯示

同時請求參數中有空格也會導致查詢失敗（阿里api文檔太簡單什么都沒說，參數只能自己慢慢調，差評）

所以此處用replace(' ','')除去空格

 

 

 

得到結果集：

 

 

完整代碼：

# coding:utf-8
# by NeilShi 11/29/2017
import requests
import hashlib
import base64
import json
import os


# 'appkey': '154430',
# 'AppSecret': 'S7ib51Kp5......Qd10Lt4490QTwpr',
# 資源：d0119848ab5......df5d8d6dc149

url = 'http://link.cainiao.com/gateway/link.do'
keys = 'S7ib51Kp5O......d10Lt4490QTwpr'

headers = {
    'content-type': 'application/x-www-form-urlencoded; charset=UTF-8'
}

results = ''   # 存放結果集


def get_address():
    try:
        with open(os.getcwd() + r'\address.txt', 'r') as f:
            address = f.readlines()
        return address
    except:
        print('打開文件失敗')
        return ''


def get_raw_input(address):
    raw_input = {
        "address": address,
        "limit": "20"
    }
    return raw_input


def get_param(sign, content):
    param = {
        'msg_type': 'CNDZK_ADDRESS_QUERY',
        'data_digest': sign,
        'logistic_provider_id': 'd011984......d7ae1df5d8d6dc149',
        'logistics_interface': content
    }
    return param


def get_data_digest(inputs, keys):
    m1 = hashlib.md5()
    m1.update((inputs + keys).encode('utf-8'))

    # base64.b64encode(m1.hexdigest()) 得到錯誤值!!!原因未知
    return base64.b64encode(m1.digest())


address_list = get_address()

for x in address_list:
    # unicode形態轉中文，去掉空格（否則查不出）
    inputs = json.dumps(get_raw_input(x)).encode('utf-8').decode('unicode_escape').replace(' ', '')

    result = requests.post(url, data=get_param(get_data_digest(inputs, keys), inputs), headers=headers)
    result = result.content.decode(encoding='utf-8')
    # print(result)
    results = results + result + '\r\n'


try:
    with open(os.getcwd()+r'\result.txt', 'w') as f:
        f.write(results)
        print("寫入成功")
except:
    print("寫文件失敗")