Pykafka.

KAFKA 메시지 대기열을위한 Python API
지금 다운로드

Pykafka. 순위 및 요약

광고

  • Rating:
  • 특허:
  • MIT/X Consortium Lic...
  • 가격:
  • FREE
  • 게시자 이름:
  • Dan Sully
  • 게시자 웹사이트:
  • http://search.cpan.org/~daniel/

Pykafka. 태그


Pykafka. 설명

Pykafka는 KAFKA 분산 게시 / 구독 메시징 서비스에 대한 메시지를 생성 할 수있는 파이썬 라이브러리로 KAFKA 인스턴스에 액세스 할 수 있고 TCP를 통해 연결할 수 있어야합니다. https://github.com/kafka-dev/kafkainstallationpip 설치 방법에 대한 사본 및 지침을 얻을 수 있습니다. kafkaproducer = kafka.producer.producer ( 'test') message = kafka.message.message ( "foo!") producer.send (메시지) sequessImport의 순서를 보내는 KAFKAPRODUCER = kafka.producer.producer ( 'test') message1 = kafka.message.message ( "foo!") message2 = kafka.message.message ( "bar!") producer.send () context manager.Import KAFKAPRODUCER = KAFKA.PODUCER.Producer ( 'test')를 사용하여 메시지로 일괄 처리합니다. producer.batch () 메시지 : 인쇄 "배치 여러 메시지 전송 .. "messages.append (kafka.message.message ("보내는 첫 번째 메시지 ") messages.append (kafka.message.message ("보내는 두 번째 메시지 ") 그들은 한 번에 전송됩니다. 컨텍스트 관리자 실행 후. 메시지를 oneImport KafkAconsumer = kafka.consumer.consumer ( 'test') message = consumer.consume () genera를 사용하여 메시지를 소비하는 메시지 Tor loopimport kafkaconsumer = kafka.consumer.consumer ( 'test') 소비자의 메시지에 대한 메시지를위한 메시지 : 인쇄물 : https://github.com/ddsully/pykafka/issuesproducts 홈페이지를 사용하십시오.


Pykafka. 관련 소프트웨어

회사 소개