[Kafka] Producer(Django-Kafka)

개요

• Django -> S3 -> Kafka
• S3 mp4디렉토리에 비디오 파일이 저장되었을 때, Kafka로 메세지 큐(MQ) 전달
• Kafka-python API를 사용하여 Python Producer 개발 예정

Install

pip install kafka-python

코드

• ./board/views.py
  • Producer 초기설정
  • topic 이름은 sendvideo 설정
    
  • Producer Send
    

결과

• Broker
  
• S3
  

URL

Walker