Django Streaming Server-Sent Events (SSE) with CrewAI

This project demonstrates Server-Sent Events (SSE) in Django using CrewAI and Daphne as the ASGI server. The system simulates an AI-powered HR assistant that communicates with candidates through streamed responses.

🚀 Features

• ASGI-Based SSE Streaming
• CrewAI Integration for AI-Powered Conversations
• Django & Daphne Setup for ASGI Support
• Environment Variables Handling with python-dotenv

---

🛠 Installation & Setup

1️⃣ Clone the Repository

git clone https://github.com/zas03ia/SSE_CrewAI.git
cd django-sse-crewai

2️⃣ Create a Virtual Environment & Install Dependencies

python -m venv venv
source venv/bin/activate  # On Windows: venv\Scripts\activate
pip install -r requirements.txt

3️⃣ Create a .env File & Add API Key

Create a .env file in the root directory:

GEMINI_API_KEY=your-google-gemini-api-key

🚨 Don't commit .env to Git. Add it to .gitignore.

4️⃣ Apply Migrations

python manage.py migrate

5️⃣ Run the ASGI Server with Daphne

python manage.py runserver

Daphne is used because it supports ASGI (for SSE).

---

🏗 ASGI Configuration

Modify settings.py

Ensure ASGI is properly configured:

ASGI_APPLICATION = "sse_demo.asgi.application"

---

🔄 Streaming Server-Sent Events (SSE)

SSE View (views.py)

# Implementation Example
from django.http import StreamingHttpResponse
from django.shortcuts import render
import asyncio

async def sse_stream(request):
    # .....  more code here
    asyncio.create_task(async_crew_execution())

    async def event_stream():
        while process['crew_executes']:
            yield f"data: {process['event']}\n\n"
            await asyncio.sleep(0.2)

    return StreamingHttpResponse(event_stream(), content_type="text/event-stream")

Configure URL Routing (urls.py)

from django.urls import path
from .views import sse_stream

urlpatterns = [
    path("sse/", sse_stream, name="sse_stream"),
]

---

🎉 Conclusion

This project showcases how to integrate CrewAI with Django and SSE streaming using an ASGI-compatible setup with Daphne. 🚀

Feel free to contribute and improve the project! 😊
Project link: https://github.com/zas03ia/SSE_CrewAI