Python SDK

from noxus_sdk.client import Client

client = Client(api_key="your_api_key")

# Get a flow and run it
flow = client.workflows.get("wf_123")
run = flow.run(
    body={"user_query": "Analyze this data"}
)

# Query knowledge base
results = client.knowledge_bases.search(
    kb_id="kb_456",
    query="What's our refund policy?"
)

# Create a custom chatbot interface
conversation = client.conversations.create(
    agent_id="agent_789",
    name="Customer Support Session"
)

# Stream responses
for chunk in conversation.chat_stream("How do I reset my password?"):
    print(chunk.content, end="", flush=True)

# Build flow programmatically
flow = client.flows.create_builder()
flow.add_node("generate_text", {
    "prompt": "Write a summary",
    "model": "gpt-4"
})
flow.add_node("save_to_file", {
    "filename": "summary.txt"
})
flow.connect("generate_text", "save_to_file")

# Deploy and run
deployed = flow.deploy("Document Summarizer")
result = deployed.run({"document": "..."})

import pandas as pd

# Process data through Noxus flows
df = pd.read_csv("customer_feedback.csv")

# Pre-fetch the workflow object
flow = client.workflows.get("sentiment_analysis")

for idx, row in df.iterrows():
    run = flow.run(
        body={"text": row['feedback']}
    )
    result = run.wait(output_only=True)
    df.at[idx, 'sentiment'] = result['sentiment']
    df.at[idx, 'category'] = result['category']

df.to_csv("analyzed_feedback.csv")

import schedule
import time
from datetime import datetime

# Pre-fetch the workflow object
flow = client.workflows.get("daily_analytics")

def daily_report():
    # Generate daily AI-powered report
    run = flow.run(
        body={"date": str(datetime.today())}
    )
    result = run.wait(output_only=True)
    
    # Email results
    send_email(result['report'])

schedule.every().day.at("09:00").do(daily_report)

while True:
    schedule.run_pending()
    time.sleep(60)