from aliyun.log import LogClient from aliyun.log import * import logging,json,re from datetime import datetime logger = logging.getLogger() def datetime_to_timestamp(date_string, date_format=”%Y-%m-%d %H:%M:%S”): dt = datetime.strptime(date_string, date_format) return int(dt.timestamp()) def query_bill_logs(json_data): accessKeyId = “” #填写accessKeyId accessKey = “” #填写accessKey endpoint = “cn-wulanchabu.log.aliyuncs.com” #填写账单数据所在的endpoint project = “bill-analysis-xxxx” #填写账单数据所在的project logstore = “aliyun_bill” #填写账单数据所在的logstore client = LogClient(endpoint, accessKeyId, accessKey) query = json_data[“query”] # from_time和to_time表示查询日志的时间范围，UNIX时间戳格式。 from_time = datetime_to_timestamp(json_data[“from_time”]) to_time = datetime_to_timestamp(json_data[“to_time”]) # query参数用于设置查询语句；line参数用于控制返回日志条数，line取值为3。 request = GetLogsRequest(project, logstore, from_time, to_time, ”, query=query, line=3, offset=0, reverse=False) response = client.get_logs(request) # 查询结果。 log_res_list=[] for log in response.get_logs(): log_res = log.contents.items() log_res_list.append(dict(log_res)) return log_res_list def main(event,context): data = event.decode(‘utf-8′) logger.info(“收到的数据：{}”.format(data)) data=json.loads(data)[“sql”] match = re.search(r’\{.*?\}’, data,re.DOTALL) if match: json_res = json.loads(match.group(0)) # 查询日志 log_res=str(query_bill_logs(json_res)) log_res = json.dumps(log_res, ensure_ascii=False, indent=4) logger.info(“查询到的数据：{}”.format(log_res)) return log_res else: logger.info(“未匹配到json”) return “无法匹配到SQL”

pip install -U aliyun-log-python-sdk -t .

{ “sql”: “{\”from_time\”:\”2025-01-01 00:00:00\”,\”to_time\”:\”2025-02-01 00:00:00\”,\”query\”:\”*|select round(coalesce(sum(PretaxAmount),0),3) from splititem_bill_transform\”}” }

用户输入	模型输出
查询1月阿里云花费金额	{“from_time”:”2025-01-01 00:00:00″,”to_time”:”2025-02-01 00:00:00″,”query”:”*|select round(coalesce(sum(PretaxAmount),0),3) from splititem_bill_transform”}

类型	简介	示例场景
智能体应用（Assistant）	是一种基于上下文对话，自主决策并调用工具来完成复杂任务的对话式 AI 应用。通过简单的配置，可以快速上手和实现基本功能。	客户服务：了解客户诉求，解决客户问题。如查询订单状态、处理退款等。 个人助理：管理日程安排、提醒事项、发送邮件等。 技术支持：了解技术问题，提供解决方案，帮助用户排除故障。
工作流应用（Workflow）	是一种将复杂任务拆解为若干子任务，以提高工作流程可控性的流程式 AI 应用。用户可以通过拖拽节点来创建自定义的任务流程。	AI 翻译：实现初步翻译、内容审校、再次优化的翻译流程，提升翻译质量。
智能体编排应用	是一种支持多智能体协作的流程式 AI 应用，使您能够编排多个智能体的执行逻辑，也可以使多个智能体自动规划和执行任务。	综合调研报告：组建一个报告撰写团队，包括负责写作意图识别、大纲书写、总结摘要、智能绘图、事件研判、段落撰写、文笔润色等任务的智能体。 软件开发团队：组建一个智能体开发团队，包括负责需求分析、系统设计、编码实现、测试调试、文档编写等任务的智能体。