Amazon MWS API：全面获取商品列表与非活跃商品数据的教程

import mws
import time

# 假设您已配置好MWS凭证，请替换为您的实际值
# marketplace_id = 'ATVPDKIKX0DER' # 示例：美国站点ID
# seller_id = 'YOUR_SELLER_ID'
# aws_access_key_id = 'YOUR_AWS_ACCESS_KEY_ID'
# mws_auth_token = 'YOUR_MWS_AUTH_TOKEN'
# secret_key = 'YOUR_SECRET_KEY'

# 初始化 Reports API 客户端
# reports_api = mws.Reports(
#     aws_access_key_id=aws_access_key_id,
#     secret_key=secret_key,
#     seller_id=seller_id,
#     mws_auth_token=mws_auth_token
# )

def get_all_listings_report(reports_api_client, marketplace_id):
    """
    请求并下载 GET_MERCHANT_LISTINGS_ALL_DATA 报告。

    Args:
        reports_api_client: 已初始化的 mws.Reports 客户端实例。
        marketplace_id: 目标亚马逊市场的ID。

    Returns:
        str: 报告保存的文件名，如果失败则返回 None。
    """
    report_type = '_GET_MERCHANT_LISTINGS_ALL_DATA_'

    try:
        # 1. 请求报告
        print(f"请求生成报告: {report_type}...")
        request_report_response = reports_api_client.request_report(
            report_type=report_type,
            marketplaceids=[marketplace_id]
        )
        # 从响应中提取 ReportRequestId
        request_id = request_report_response.parsed['ReportRequestInfo']['ReportRequestId']['value']
        print(f"报告请求ID: {request_id}")

        # 2. 轮询报告状态，直到报告生成完成
        report_id = None
        while report_id is None:
            print("等待报告生成中，请稍候...")
            time.sleep(60) # 每60秒检查一次报告状态

            get_report_request_list_response = reports_api_client.get_report_request_list(
                reportrequestids=[request_id] # 使用 ReportRequestId 查询
            )
            report_request_info = get_report_request_list_response.parsed['ReportRequestInfo']

            if 'ReportId' in report_request_info:
                report_id = report_request_info['ReportId']['value']
                print(f"报告已生成，报告ID: {report_id}")
            elif report_request_info['ReportProcessingStatus']['value'] == '_CANCELLED_':
                print("报告请求被取消。")
                return None
            elif report_request_info['ReportProcessingStatus']['value'] == '_DONE_NO_DATA_':
                print("报告已生成，但无数据。")
                return None
            else:
                print(f"报告处理状态: {report_request_info['ReportProcessingStatus']['value']}")

        # 3. 获取报告内容
        print(f"下载报告内容 (报告ID: {report_id})...")
        get_report_response = reports_api_client.get_report(report_id=report_id)
        report_content = get_report_response.parsed # 报告内容通常是字符串

        # 将报告内容保存到文件
        file_