作者:鲨鱼 | 时间:2025年8月12日 原创文章,首发于CSDN,如需转载,请注明出处。
目录
引言淘宝开放平台概览接入淘宝API实战:同步淘宝订单数据解析与处理订单数据生成销售报表将数据写入数据库(可选)总结结束语作者简介
一、引言
在当今电商竞争激烈的市场中,如何高效地管理订单数据成为了每一个商家必须面对的问题。手动处理订单不仅耗时费力,还容易出错。通过淘宝开放平台提供的强大API接口,我们可以实现订单数据的自动化同步,大幅提升工作效率。
本文将详细介绍如何利用淘宝开放平台API高效同步电商订单数据,并教你如何进一步分析这些数据以生成详细的销售报表。
二、淘宝开放平台概览
什么是淘宝开放平台?
淘宝开放平台(Taobao Open Platform, TOP)是阿里巴巴集团为第三方开发者和合作伙伴提供的一套全面的API服务,旨在帮助他们更便捷地访问淘宝丰富的商品、交易、用户等信息资源。
主要功能
订单管理:获取、更新订单状态。商品管理:查询、修改商品信息。用户管理:获取买家信息。物流管理:查询物流信息、发货通知等。
为什么选择淘宝开放平台?
自动化操作:减少手动操作,提升效率。实时数据同步:确保数据最新、准确。定制化解决方案:根据业务需求灵活调整。
三、接入淘宝API
步骤1:创建应用并获取App Key和Secret
登录淘宝开放平台。创建新应用,填写必要信息(应用名称、描述等)。完成后,你会获得App Key和App Secret,这是调用API的关键凭证。
步骤2:获取Access Token
为了能够访问店铺的订单信息,你需要获得用户的授权。
示例:获取Authorization Code
构造OAuth授权URL:
https://oauth.taobao.com/authorize?
response_type=code&
client_id=your_app_key&
redirect_uri=your_callback_url&
state=security_token%3D123456
用户同意授权后,会重定向到你设置的回调地址,并附带一个code参数,使用该参数换取access_token。
import requests
def get_access_token(app_key, app_secret, code, redirect_uri):
url = "https://oauth.taobao.com/token"
payload = {
'grant_type': 'authorization_code',
'code': code,
'client_id': app_key,
'client_secret': app_secret,
'redirect_uri': redirect_uri
}
response = requests.post(url, data=payload)
return response.json()
# 示例调用
app_key = 'your_app_key'
app_secret = 'your_app_secret'
code = 'received_code_from_redirect'
redirect_uri = 'your_callback_url'
token_info = get_access_token(app_key, app_secret, code, redirect_uri)
print(token_info)
四、实战:同步淘宝订单数据
使用接口:taobao.trades.sold.get
该接口用于批量获取卖家已卖出的交易数据。
import time
import requests
from hashlib import md5
def generate_sign(params, secret):
"""生成签名"""
sorted_params = sorted(params.items())
query_string = '&'.join([f"{k}{v}" for k, v in sorted_params])
sign_str = secret + query_string + secret
return md5(sign_str.encode()).hexdigest().upper()
def get_trades_sold_list(app_key, app_secret, session_key):
url = "https://eco.taobao.com/router/rest"
timestamp = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
params = {
'method': 'taobao.trades.sold.get',
'app_key': app_key,
'session': session_key,
'timestamp': timestamp,
'format': 'json',
'v': '2.0',
'sign_method': 'md5',
'fields': 'tid,status,pay_time,receiver_name,receiver_mobile,receiver_address,buyer_message,total_fee,payment,num_iid,title,price,num',
'start_created': '2025-07-01 00:00:00',
'end_created': '2025-07-31 23:59:59',
'page_no': 1,
'page_size': 50
}
params['sign'] = generate_sign(params, app_secret)
response = requests.post(url, data=params)
return response.json()
# 示例调用
app_key = 'your_app_key'
app_secret = 'your_app_secret'
session_key = 'your_session_key'
trades = get_trades_sold_list(app_key, app_secret, session_key)
print(trades)
五、解析与处理订单数据
解析订单结构,提取关键字段
def parse_order(order):
return {
'tid': order.get('tid'),
'status': order.get('status'),
'pay_time': order.get('pay_time'),
'receiver_name': order.get('receiver_name'),
'receiver_mobile': order.get('receiver_mobile'),
'receiver_address': order.get('receiver_address'),
'buyer_message': order.get('buyer_message'),
'total_fee': float(order.get('total_fee', 0)),
'payment': float(order.get('payment', 0)),
'items': [
{
'num_iid': item.get('num_iid'),
'title': item.get('title'),
'price': float(item.get('price', 0)),
'num': int(item.get('num', 0))
}
for item in order.get('orders', [])
]
}
# 解析并打印
parsed_orders = [parse_order(trade) for trade in trades.get('trades_sold_get_response', {}).get('trades', [])]
for parsed in parsed_orders:
print(parsed)
六、生成销售报表
聚合数据并统计关键指标
def generate_sales_report(orders):
total_sales = sum(order['payment'] for order in orders)
order_count = len(orders)
average_order_value = total_sales / order_count if order_count > 0 else 0
# 商品销售统计
sales_by_item = {}
for order in orders:
for item in order['items']:
key = (item['num_iid'], item['title'])
if key not in sales_by_item:
sales_by_item[key] = {
'quantity': 0,
'revenue': 0
}
sales_by_item[key]['quantity'] += item['num']
sales_by_item[key]['revenue'] += item['price'] * item['num']
return {
'total_sales': total_sales,
'order_count': order_count,
'average_order_value': average_order_value,
'sales_by_item': sales_by_item
}
# 生成报表
sales_report = generate_sales_report(parsed_orders)
print(sales_report)
输出报表为CSV
import csv
def export_to_csv(report, filename='sales_report.csv'):
with open(filename, mode='w', newline='', encoding='utf-8') as file:
writer = csv.writer(file)
# 写入表头
writer.writerow(['Total Sales', 'Order Count', 'Average Order Value'])
writer.writerow([report['total_sales'], report['order_count'], report['average_order_value']])
# 写入商品销售统计
writer.writerow([])
writer.writerow(['Item ID', 'Item Title', 'Quantity Sold', 'Revenue'])
for (item_id, title), stats in report['sales_by_item'].items():
writer.writerow([item_id, title, stats['quantity'], stats['revenue']])
# 导出报表
export_to_csv(sales_report)
七、将数据写入数据库(可选)
创建MySQL表结构
CREATE TABLE sales_reports (
id INT AUTO_INCREMENT PRIMARY KEY,
total_sales DECIMAL(10, 2),
order_count INT,
average_order_value DECIMAL(10, 2),
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
CREATE TABLE sales_by_items (
id INT AUTO_INCREMENT PRIMARY KEY,
report_id INT,
item_id BIGINT,
item_title VARCHAR(255),
quantity_sold INT,
revenue DECIMAL(10, 2),
FOREIGN KEY (report_id) REFERENCES sales_reports(id)
);
插入数据到数据库
import mysql.connector
def insert_into_db(report):
conn = mysql.connector.connect(
host="localhost",
user="root",
password="password",
database="sales_db"
)
cursor = conn.cursor()
# 插入总销售数据
insert_report_query = """
INSERT INTO sales_reports (total_sales, order_count, average_order_value)
VALUES (%s, %s, %s)
"""
cursor.execute(insert_report_query, (
report['total_sales'],
report['order_count'],
report['average_order_value']
))
report_id = cursor.lastrowid
# 插入商品销售统计
insert_item_query = """
INSERT INTO sales_by_items (report_id, item_id, item_title, quantity_sold, revenue)
VALUES (%s, %s, %s, %s, %s)
"""
for (item_id, title), stats in report['sales_by_item'].items():
cursor.execute(insert_item_query, (
report_id,
item_id,
title,
stats['quantity'],
stats['revenue']
))
conn.commit()
cursor.close()
conn.close()
# 插入报表数据
insert_into_db(sales_report)
八、总结
通过本文的讲解,你已经掌握了以下技能:
如何接入淘宝开放平台并获取API权限;如何调用订单接口同步订单数据;如何解析订单结构并提取关键字段;如何生成销售报表并导出为CSV文件;如何将报表数据写入数据库以便后续分析。
这些技能不仅能帮助你提升电商运营效率,还能为后续的BI分析、数据看板、自动化系统开发打下坚实基础。
九、结束语
电商数据的自动化处理,正在成为电商从业者必备的核心能力之一。掌握淘宝订单接口,意味着你已经迈出了自动化运营的第一步。
希望本文能为你提供实用的技术指导和清晰的开发思路。无论你是电商创业者、运营人员,还是开发者,都可以通过本文的示例代码快速上手,打造属于自己的订单管理系统。
十、作者简介
鲨鱼,全栈开发者,电商系统架构师,CSDN博客专家,专注于电商API对接、数据自动化处理、ERP系统开发等领域。拥有多年电商平台对接经验,擅长使用Python、Java等语言实现电商数据的采集、分析与可视化展示。