Observability for Qianfan with Opik

1
from opik.integrations.openai import track_openai
2
from openai import OpenAI
3
4
# Initialize the OpenAI client with your Qianfan base URL
5
client = OpenAI(
6
    base_url="https://api.baiduqianfan.ai/v1",
7
    api_key="bce-v3/ALTAK-XXXXXXXX/XXXXXXXXXXXXXXXX",  # Qianfan bearer token
8
    default_headers={"appid": "app-xxxxxx"}  # Optional Qianfan appid
9
)
10
client = track_openai(client)
11
12
response = client.chat.completions.create(
13
    model="ernie-4.0-turbo-8k",  # Use a model name from Qianfan
14
    messages=[
15
        {"role": "user", "content": "Hello, world!"}
16
    ],
17
    temperature=0.7,
18
    max_tokens=100
19
)
20
21
print(response.choices[0].message.content)

1
from opik import track
2
from opik.integrations.openai import track_openai
3
from openai import OpenAI
4
5
client = OpenAI(
6
    base_url="https://api.baiduqianfan.ai/v1",
7
    api_key="bce-v3/ALTAK-XXXXXXXX/XXXXXXXXXXXXXXXX",  # Qianfan bearer token
8
    default_headers={"appid": "app-xxxxxx"}  # Optional Qianfan appid
9
)
10
client = track_openai(client)
11
12
@track
13
def summarize_report(text: str) -> str:
14
    response = client.chat.completions.create(
15
        model="ernie-4.0-turbo-8k",
16
        messages=[
17
            {"role": "user", "content": text}
18
        ]
19
    )
20
21
    return response.choices[0].message.content
22
23
summary = summarize_report("Summarize this report in 3 bullets.")
24
print(summary)