[ALIYUN]account_info_dic = {"阿里云账号1":{"uid":"请填写阿里云账号uid","ak":"请填写ak","sk":"请填写sk"},"阿里云账号2":{"uid":"请填写阿里云账号uid","ak":"请填写ak","sk":"请填写sk"}}

import json,configparser,logging,asynciofrom concurrent.futures import ThreadPoolExecutorfrom typing import Listfrom datetime import datetimefrom dateutil.relativedelta import relativedeltafrom tenacity import retry, stop_after_attempt, wait_fixedfrom alibabacloud_bssopenapi20171214.client import Client as BssOpenApi20171214Clientfrom alibabacloud_tea_openapi import models as open_api_modelsfrom alibabacloud_tea_util import models as util_modelsfrom alibabacloud_credentials.models import Config as CreConfigfrom alibabacloud_credentials.client import Client as CredentialClientfrom alibabacloud_bssopenapi20171214 import models as bss_open_api_20171214_models# 日志配置logging.basicConfig(level=logging.INFO,format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')logger = logging.getLogger(__name__)# 全局常量定义（避免污染类）current = datetime.now()months = [(current - relativedelta(months=i)).strftime("%Y-%m") for i in range(3, 0, -1)]class Billing:    # 类级配置    config = configparser.ConfigParser()    config.read('config.ini')    account_info_dic = json.loads(config['ALIYUN']['account_info_dic'])    executor = ThreadPoolExecutor(max_workers=100)    semaphore = asyncio.Semaphore(100)    months = months  # 将 months 作为类属性引用外部定义    @staticmethod    def create_client(ak: str, sk: str) -> BssOpenApi20171214Client:        """创建阿里云 BSS API 客户端"""        credentials_config = CreConfig(            type='access_key',            access_key_id=ak,            access_key_secret=sk,        )        credential = CredentialClient(credentials_config)        client_config = open_api_models.Config(            credential=credential        )        client_config.endpoint = 'business.aliyuncs.com'        return BssOpenApi20171214Client(client_config)    @staticmethod    @retry(stop=stop_after_attempt(3), wait=wait_fixed(2))    def get_credit_amount(args: List[str]) -> tuple:        """获取账户信用额度"""        client = args[0]        try:            runtime = util_models.RuntimeOptions()            res = client.query_account_balance_with_options(runtime).body.data            available_amount = res.available_amount            credit_amount = res.credit_amount            return available_amount, credit_amount        except Exception as e:            logger.error("获取信用额度失败", exc_info=True)            return (0, 0)    @staticmethod    async def async_get_credit_amount(client: BssOpenApi20171214Client):        """异步调用 get_credit_amount 方法"""        loop = asyncio.get_event_loop()        return await loop.run_in_executor(Billing.executor, Billing.get_credit_amount, [client])    @staticmethod    @retry(stop=stop_after_attempt(3), wait=wait_fixed(2))    def get_history_billing_data(client, account_uid: str, months_list: list) -> str:        """获取历史账单数据"""        history_amount = ""        for billing_cycle in months_list:            page_num = 1            page_size = 100            pretax_amount = 0            while True:                query_account_bill_request = bss_open_api_20171214_models.QueryAccountBillRequest(                    billing_cycle=billing_cycle,                    owner_id=account_uid,                    granularity='MONTHLY',                    page_num=page_num,                    page_size=page_size                )                runtime = util_models.RuntimeOptions()                res = client.query_account_bill_with_options(query_account_bill_request, runtime).body.data.items.item                if not res:                    break                for re in res:                    pretax_amount += re.pretax_amount                page_num += 1            history_amount += f"{billing_cycle}: {round(pretax_amount, 2)}元 "        return history_amount    @staticmethod    async def async_get_history_billing_data(client, account_uid: str, months_list: list):        """异步调用 get_history_billing_data 方法"""        loop = asyncio.get_event_loop()        return await loop.run_in_executor(Billing.executor, Billing.get_history_billing_data, client, account_uid, months_list)    @staticmethod    async def process_account(account_name: str, account_info: dict):        """处理单个账户的信用额度与账单信息"""        client = Billing.create_client(account_info["ak"], account_info["sk"])        async with Billing.semaphore:            available_amount, credit_amount = await Billing.async_get_credit_amount(client)            history_amount = await Billing.async_get_history_billing_data(client, account_info["uid"], Billing.months)        return account_name, account_info["uid"], available_amount, credit_amount, history_amount    @staticmethod    async def get_all_credit_amount_async():        """并发获取所有账户信用额度和账单信息"""        tasks = [            Billing.process_account(account_name, account_info)            for account_name, account_info in Billing.account_info_dic.items()        ]        results = await asyncio.gather(*tasks)        message = ""        for account_name, uid, available_amount, credit_amount, history_amount in results:            message += "\n{}（{}）:\n  可用额度为{}元\n  信控额度为{}元\n  前三个月消费金额为 {}".format(                account_name, uid, available_amount, credit_amount, history_amount            )        logger.info(message)        return message    @staticmethod    async def main():        """主入口方法"""        return await Billing.get_all_credit_amount_async()def main(event,context):    """模块化主函数入口"""    return asyncio.run(Billing.main())

# -*- coding: utf-8 -*-# 导入所需的阿里云SDK模块和其他依赖库from alibabacloud_bssopenapi20171214.client import Client as BssOpenApi20171214Clientfrom alibabacloud_credentials.client import Client as CredentialClientfrom alibabacloud_tea_openapi import models as open_api_modelsfrom alibabacloud_bssopenapi20171214 import models as bss_open_api_20171214_modelsfrom alibabacloud_tea_util import models as util_modelsfrom alibabacloud_credentials.models import Config as CreConfigfrom ratelimit import limits, sleep_and_retry  # 用于限制API调用频率import logging, json# 初始化日志记录器logger = logging.getLogger()# 阿里云访问密钥（需要替换为真实值）ak = "请输入AK"sk = "请输入SK"# 订单类型映射表，将英文订单类型转换为中文描述order_type_mapping = {'New': '新购','Renew': '续费','Upgrade': '升级','TempUpgrade': '短时升级','Downgrade': '降级','Refund': '退款','Convert': '付费类型转换','ResizeDisk': '调整磁盘大小','CompensatoryRenew': '补偿续费','IncreaseUpgrade': '带宽升级','Exchange': '换购','ChangeOperatingSystem': '更换操作系统'}class Sample:    def __init__(self):        pass    @staticmethod    def create_client() -> BssOpenApi20171214Client:        """创建BSS Open API客户端"""        credentialsConfig = CreConfig(type='access_key',access_key_id=ak,access_key_secret=sk,)        credential = CredentialClient(credentialsConfig)        config = open_api_models.Config(credential=credential)        config.endpoint = f'business.vpc-proxy.aliyuncs.com'        return BssOpenApi20171214Client(config)    @sleep_and_retry    @limits(calls=10, period=1)  # 限制每秒最多调用10次    @staticmethod    def GetOrderDetail(order_id):        """获取订单详情信息，包括实例ID和优惠券抵扣金额"""        client = Sample.create_client()        get_order_detail_request = bss_open_api_20171214_models.GetOrderDetailRequest(order_id=order_id)        runtime = util_models.RuntimeOptions()        order_list = client.get_order_detail_with_options(get_order_detail_request, runtime).body.data.order_list.order        voucher_amount = 0  # 优惠券抵扣金额初始化        # 遍历订单列表，计算优惠券抵扣金额        for order in order_list:            instance_ids = order.instance_ids  # 获取实例ID            voucher = order.extend_infos.get("DeductedByCoupons", "0")  # 获取优惠券抵扣信息            voucher_amount += float(voucher)  # 累加优惠券金额        return instance_ids, voucher_amount  # 返回实例ID和优惠券金额    @sleep_and_retry    @limits(calls=10, period=1)  # 限制API调用频率    @staticmethod    def main(start_time, end_time):        """主函数：查询指定时间范围内的订单信息"""        client = Sample.create_client()  # 创建API客户端        page_num = 1  # 当前页码        page_size = 100  # 每页数量        result_dict = {}  # 结果字典，存储统计信息        while True:            # 创建查询订单的请求            query_orders_request = bss_open_api_20171214_models.QueryOrdersRequest(                create_time_start=start_time,  # 开始时间                create_time_end=end_time,  # 结束时间                page_num=page_num,  # 当前页码                page_size=page_size,  # 每页数量                subscription_type='Subscription'  # 查询预付费订单            )            runtime = util_models.RuntimeOptions()            # 记录日志：开始查询第N页数据            logger.info("第{}页订单数据开始查询".format(page_num))            # 发送请求并获取响应            order_list = client.query_orders_with_options(query_orders_request, runtime).body.data.order_list.order            if order_list == []:  # 如果没有更多数据，退出循环                break            else:                page_num += 1  # 否则增加页码            order_info = []  # 存储订单详细信息            # 处理每个订单            for order in order_list:                if order.payment_status == "Paid":  # 只处理已支付的订单                    logger.info(str(order.__dict__))  # 记录订单原始信息                    product_code = order.product_code  # 获取产品代码                    # 对一些特殊产品代码进行重命名                    if product_code == 'dide': product_code = 'DataWorks'                    elif product_code == 'dds': product_code = 'MongoDB'                    elif product_code in ['kvstore', 'redisa']: product_code = 'Redis'                    elif product_code == 'odpsplus': product_code = 'MaxCompute'                    # 获取订单类型、金额等信息                    order_type = order_type_mapping[order.order_type]                    pretax_amount = order.pretax_amount                    order_id = order.order_id                    # 获取订单的实例ID和优惠券抵扣金额                    instance_ids, voucher_amount = Sample.GetOrderDetail(order_id)                    # 计算实际金额（原价+优惠券）                    amount = pretax_amount + voucher_amount                    # 收集订单信息                    order_info.append({"order_id": order_id,"order_type": order_type,"product_code": product_code,"amount": amount,"instance_ids": instance_ids})                    # 汇总统计信息                    key = (product_code, order_type)                    if key in result_dict: result_dict[key] += amount                    else: result_dict[key] = amount        return result_dict, order_info  # 返回结果def main(event, context):    """处理事件触发的入口函数"""    data = event.decode('utf-8')  # 解码输入数据    logger.info("收到的数据：{}".format(data))  # 记录接收到的数据    # 解析JSON数据中的时间范围    time = json.loads(data)["time"].split(",")    start_time = time[0]  # 开始时间    end_time = time[1]  # 结束时间    # 记录时间范围    logger.info("开始时间：{}".format(start_time))    logger.info("结束时间：{}".format(end_time))    # 查询订单信息    result_dict, order_info = Sample.main(start_time, end_time)    # 计算总金额    amount = 0    for key, value in result_dict.items():        amount += value    # 记录统计结果    logger.info("总金额：{}".format(str(amount)))    logger.info("订单汇总：{}".format(str(result_dict)))    logger.info("订单详情：{}".format(str(order_info)))    # 构造响应JSON    response_json = json.dumps({"amount": str(amount),"result_dict": str(result_dict),"order_info": str(order_info)}, indent=4)    # 记录返回结果    logger.info("返回结果：{}".format(response_json))    return response_json  # 返回结果