도움이 되셨다면, 광고 한번만 눌러주세요. 블로그 관리에 큰 힘이 됩니다 ^^ ## Producer from time import sleep from json import dumps from kafka import KafkaProducer import numpy as np def on_send_success(record_metadata): print("topic : {} , partition : {} , offset : {}".\ format( record_metadata.topic , record_metadata.partition , record_metadata.offset)) def on_send_error(excp): log.error('I am an errback', exc_info=excp) p..

https://data-newbie.tistory.com/229 Python thread 공부해보기-1 최근에 머 하나를 병렬적으로 실행하고 싶은게 있었다. 그래서 멀티프로세싱으로 하려고 시도를 했는데, 동작하지 않아서 threading을 활용해서 thread 형식으로 했다. 하지만 내가 알기론 GIL? 이것 때문에 threa.. data-newbie.tistory.com 앞에서는 threading과 동기화에 대해서 써봤다. 이번에는 queue를 사용해서 스레드 간 데이터 전달 과정 먼가 이 producer와 consumer를 보면 kafka가 생각난다. 먼가 같은 방식인 것 같기도 한데... import threading from queue import Queue def creator(data, q):..