Ollama: واجهة برمجة التطبيقات المتوافقة مع OpenAI

from openai import OpenAI

# قبل: OpenAI سحابي
# client = OpenAI(api_key="sk-xxx")

# بعد: Ollama محلي (سطران فقط تغيرا!)
client = OpenAI(base_url="http://localhost:11434/v1", api_key="ollama")

from openai import OpenAI

# التوجيه إلى خادم Ollama المحلي
client = OpenAI(
    base_url="http://localhost:11434/v1",
    api_key="ollama"  # أي سلسلة غير فارغة تعمل
)

# إكمال المحادثة (استخدام مطابق لواجهة OpenAI API)
response = client.chat.completions.create(
    model="qwen2.5",
    messages=[
        {"role": "system", "content": "You are a helpful assistant."},
        {"role": "user", "content": "Explain RAG in 2 sentences"}
    ],
    temperature=0.3
)

print(response.choices[0].message.content)

# Execution successful

from openai import OpenAI

client = OpenAI(
    base_url="http://localhost:11434/v1",
    api_key="ollama"
)

# المتدفقة تعمل بشكل متطابق
stream = client.chat.completions.create(
    model="qwen2.5",
    messages=[{"role": "user", "content": "Write a short poem about AI"}],
    stream=True,
    temperature=0.7
)

for chunk in stream:
    if chunk.choices[0].delta.content:
        print(chunk.choices[0].delta.content, end="", flush=True)
print()

# Execution successful

from openai import OpenAI

client = OpenAI(
    base_url="http://localhost:11434/v1",
    api_key="ollama"
)

# التضمينات: فقط غيّر اسم النموذج
response = client.embeddings.create(
    model="nomic-embed-text",  # كان: text-embedding-3-small
    input="What is the return policy for electronics?"
)

print(f"Embedding dimension: {len(response.data[0].embedding)}")
# 768 بُعد لـ nomic-embed-text

# Execution successful

from openai import OpenAI
import json

client = OpenAI(
    base_url="http://localhost:11434/v1",
    api_key="ollama"
)

# وضع JSON: واجهة API متطابقة
response = client.chat.completions.create(
    model="qwen2.5",
    messages=[
        {"role": "system", "content": "You are a product catalog API."},
        {"role": "user", "content": "List 3 laptops under $500"}
    ],
    response_format={"type": "json_object"},
    temperature=0.3
)

data = json.loads(response.choices[0].message.content)
print(json.dumps(data, indent=2))

# Execution successful

from openai import OpenAI
import json

client = OpenAI(
    base_url="http://localhost:11434/v1",
    api_key="ollama"
)

# بدلاً من Function Calling، استخدم وضع JSON + موجه
tools = {
    "get_order_status": {"order_id": "string"},
    "process_refund": {"order_id": "string", "amount": "number"},
    "search_products": {"query": "string", "category": "string"}
}

response = client.chat.completions.create(
    model="qwen2.5",
    messages=[
        {"role": "system", "content": f"""You are a customer service bot.
Available tools: {json.dumps(tools)}
If you need to call a tool, respond with JSON: {{"tool": "name", "args": {{...}}}}
Otherwise, respond normally."""},
        {"role": "user", "content": "Where is my order #12345?"}
    ],
    response_format={"type": "json_object"},
    temperature=0.2
)

result = json.loads(response.choices[0].message.content)
if "tool" in result:
    print(f"Call tool: {result['tool']} with args: {result['args']}")
    # Call: get_order_status with {"order_id": "12345"}
else:
    print("Direct response:", result)

Direct response:

# ============================================
# شامل: ترحيل SupportBot
# من GPT-4 إلى Ollama المحلي باستخدام OpenAI SDK
# ============================================

from openai import OpenAI
import json
from dataclasses import dataclass
from typing import Optional

@dataclass
class SupportBotMigrator:
    """SupportBot مع تبديل سهل بين OpenAI/Ollama."""

    # غيّر هذين السطرين للتبديل بين السحابة والمحلي
    base_url: str = "http://localhost:11434/v1"
    api_key: str = "ollama"
    model: str = "qwen2.5"
    temperature: float = 0.4

    def __post_init__(self):
        self.client = OpenAI(
            base_url=self.base_url,
            api_key=self.api_key
        )
        self.system_prompt = (
            "You are SupportBot, an e-commerce customer service agent. "
            "Be polite, concise, and helpful. "
            "For order queries, ask for order number. "
            "If unsure, say 'Let me connect you with a human agent.'"
        )
        self.messages = [
            {"role": "system", "content": self.system_prompt}
        ]

    def chat(self, user_input: str) -> str:
        self.messages.append({"role": "user", "content": user_input})
        try:
            response = self.client.chat.completions.create(
                model=self.model,
                messages=self.messages[-10:],  # نافذة منزلقة
                temperature=self.temperature
            )
            reply = response.choices[0].message.content
            self.messages.append({"role": "assistant", "content": reply})
            return reply
        except Exception as e:
            self.messages.pop()
            return f"Error: {e}"

    def classify_intent(self, user_input: str) -> dict:
        response = self.client.chat.completions.create(
            model=self.model,
            messages=[
                {"role": "system", "content": """Classify the customer intent.
Return JSON: {"intent": "order_status|refund|product_query|shipping|other", "confidence": 0.0-1.0}"""},
                {"role": "user", "content": user_input}
            ],
            response_format={"type": "json_object"},
            temperature=0.1
        )
        return json.loads(response.choices[0].message.content)

    def generate_embedding(self, text: str) -> list[float]:
        response = self.client.embeddings.create(
            model="nomic-embed-text",
            input=text
        )
        return response.data[0].embedding

# الاستخدام - مقارنة السحابة مقابل المحلي
if __name__ == "__main__":
    # Ollama محلي (الإعداد الحالي)
    bot = SupportBotMigrator()

    # التبديل إلى OpenAI سحابي (أزل التعليق للاستخدام)
    # bot = SupportBotMigrator(
    #     base_url="https://api.openai.com/v1",
    #     api_key="sk-your-key",
    #     model="gpt-4"
    # )

    queries = [
        "Where is my order #88765?",
        "I want a refund for damaged goods",
        "Does this laptop have HDMI port?"
    ]

    for q in queries:
        intent = bot.classify_intent(q)
        reply = bot.chat(q)
        print(f"Q: {q}")
        print(f"Intent: {intent}")
        print(f"A: {reply[:100]}...")
        print()