clean_agent

.env

@@ -17,6 +17,10 @@ GEMINI_API_KEY=AIzaSyAkt1l9Kw1CQgHFzTpla0vgt0OE53fr-BI
 DEEPSEEK_API_KEY=sk-35504b23097f4662899638869c2a63b3
 DEEPSEEK_BASE_URL=https://dashscope.aliyuncs.com/compatible-mode/v1
 
+# openrouter
+OPENROUTER_API_TOKEN = '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'
+OPENROUTER_BASE_URL = 'https://openrouter.ai/api/v1'
+
 # 代理
 DYNAMIC_HTTP_PROXY=http://127.0.0.1:7890
 

llm/openrouter.py

@@ -0,0 +1,94 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import os
+import json
+from typing import Any, Dict, Optional
+from enum import Enum
+from dotenv import load_dotenv
+import google.generativeai as genai
+
+from openai import OpenAI
+
+
+class OpenRouterModel(Enum):
+    """OpenRouter支持的模型枚举"""
+    # Google模型
+    GEMINI_25_FLASH = "google/gemini-2.5-flash"
+
+
+class OpenRouterProcessor:
+    
+    def __init__(self, openRouterModel = OpenRouterModel.GEMINI_25_FLASH.value):
+        # 加载环境变量
+        load_dotenv()
+        
+        # 获取API密钥
+        api_key = os.getenv('OPENROUTER_API_TOKEN')
+        base_url = os.getenv('OPENROUTER_BASE_URL')
+
+        self.client = OpenAI(api_key=api_key, base_url=base_url)
+        self.model = openRouterModel.value
+
+    
+    def process(self, content: Any, system_prompt: str) -> Dict[str, Any]:
+
+        try:
+            # 处理输入内容格式
+            if isinstance(content, dict):
+                # 将字典转换为JSON字符串
+                formatted_content = json.dumps(content, ensure_ascii=False)
+            else:
+                formatted_content = content
+            # 使用OpenRouter API调用模型
+            response = self.client.chat.completions.create(
+                model=self.model,  # 使用枚举值
+                messages=[
+                    {"role": "system", "content": system_prompt},
+                    {"role": "user", "content": formatted_content},
+                ],
+                stream=False
+            )
+            return response.choices[0].message.content  
+                
+        except Exception as e:
+            print(f"DeepSeek API 调用失败: {e}")
+            return {"error": str(e), "content": content} 
+            
+    def batch_process(self, contents: list, system_prompt: str) -> list:
+        results = []
+        for content in contents:
+            result = self.process(content, system_prompt)
+            results.append(result)
+        return results
+
+
+def main():
+    # 创建OpenRouterProcessor实例
+    processor = OpenRouterProcessor(OpenRouterModel.GEMINI_25_FLASH)
+    
+    # 示例系统提示
+    system_prompt = "你是一个有用的AI助手，请简洁地回答问题。"
+    
+    # 示例用户输入
+    user_input = "什么是人工智能？"
+    
+    # 处理单个请求
+    print("\n处理单个请求:")
+    result = processor.process(user_input, system_prompt)
+    print(f"输入: {user_input}")
+    print(f"输出: {result}")
+    
+    # 处理批量请求
+    print("\n处理批量请求:")
+    batch_inputs = ["什么是机器学习？", "什么是深度学习？"]
+    batch_results = processor.batch_process(batch_inputs, system_prompt)
+    
+    for i, (input_text, result) in enumerate(zip(batch_inputs, batch_results)):
+        print(f"\n请求 {i+1}:")
+        print(f"输入: {input_text}")
+        print(f"输出: {result}")
+
+
+if __name__ == "__main__":
+    main()