pykafka. Python API para a fila de mensagens Kafka
Baixe Agora

pykafka. Classificação e resumo

pykafka. Tag

Biblioteca Python. Pitão mensagem

pykafka. Descrição

Pykafka é uma biblioteca Python que permite que você produza mensagens para o serviço de mensagens de publicação / assinatura do Kafka Distribuided.RequirementsYou precisa ter acesso ao seu kafka instance e ser capaz de se conectar através do TCP. Você pode obter uma cópia e instruções sobre como configurar Kafka em https://github.com/kafka-dev/kafkkainstallationpip instalar pykafkausagesending um simples messageImport kafkaproducer = kafka.producer.producer ('teste') mensagem = kafka.message.message ("Foo!") Produtor.Send (mensagem) Enviando uma sequência de mensagensimport kafkaproducer = kafka.producer.producer ('teste') Message1 = kafka.message.Message ("foo!") Message2 = kafka.message.message ( "Bar!") Produtor.Send () Lote um monte de mensagens usando um gerenciador de contexto.Import kafkaproducer = kafka.producer.producer ('teste') com produtor.batch () como mensagens: Imprimir "Lootching Um envio de várias mensagens .. "Messages.Append (kafka.message.message (" primeira mensagem para enviar ") mensagens.Append (Kafka.Message.Message (" segunda mensagem para enviar ") eles serão enviados de uma só vez, Após a execução do gerenciador de contexto.Consuming mensagens um por oneimport kafkaconsumer = kafka.consumer.consumer ('teste') mensagens = consumer.consume () consumindo mensagens usando um gênero tor loopimport kafkaconsumer = kafka.consumer.consumer ('teste') para mensagem em Consumer.loop (): Print MessageContact: Por favor, use os problemas do github: https://github.com/dsully/pykafka/issuesproduct's homepage

pykafka. Software Relacionado