Brand Safety & Ad Verification Pipeline

from mixpeek import Mixpeek

client = Mixpeek(api_key="YOUR_API_KEY")

namespace = client.namespaces.create(name="brand-safety")
collection = client.collections.create(
    namespace_id=namespace.id,
    name="ad-creatives",
    extractors=[
        "brand-safety-violence",
        "brand-safety-adult",
        "brand-safety-hate",
        "brand-safety-drugs"
    ]
)

# Real-time creative check
async def check_creative(creative_url):
    result = client.buckets.upload(
        collection_id=collection.id,
        url=creative_url
    )
    # Check safety scores in the processed document
    doc = client.documents.get(document_id=result.document_id)
    return {
        "safe": all(s > 0.85 for s in doc.safety_scores.values()),
        "scores": doc.safety_scores
    }