AI Content Moderation Pipeline

from mixpeek import Mixpeek

client = Mixpeek(api_key="YOUR_API_KEY")

namespace = client.namespaces.create(name="moderation")
collection = client.collections.create(
    namespace_id=namespace.id,
    name="user-uploads",
    extractors=["nsfw-detection", "violence-detection", "text-toxicity"]
)

# Process user-uploaded content
client.buckets.upload(
    collection_id=collection.id,
    url="s3://your-bucket/user-uploads/"
)

# Query for flagged content
flagged = client.documents.search(
    namespace_id=namespace.id,
    filters={"safety_score": {"$lt": 0.85}}
)