Как добавить данные в топи c с помощью AvroProducer - PullRequest
Новая
       24

Как добавить данные в топи c с помощью AvroProducer

0 голосов
/ 01 апреля 2020

У меня есть топи c со следующей схемой. Может ли кто-нибудь помочь мне, как добавить данные в разные поля. 

{
  "name": "Project",
  "type": "record",
  "namespace": "abcdefg",
  "fields": [   
    {
      "name": "Object",
      "type": {
        "name": "Object",
        "type": "record",
        "fields": [
          {
            "name": "Number_ID",
            "type": "int"
          },
          {
            "name": "Accept",
            "type": "boolean"
          }
        ]
      }
    },
    {
      "name": "DataStructureType",
      "type": "string"
    },
    {
      "name": "ProjectID",
      "type": "string"
    }
  ]
}

Я попробовал следующий код. Я получаю список не повторяемый или список выходит за пределы диапазона. 

from confluent_kafka import avro
from confluent_kafka.avro import AvroProducer


AvroProducerConf = {'bootstrap.servers': 'localhost:9092','schema.registry.url': 'http://localhost:8081'}
value_schema = avro.load('project.avsc')

avroProducer = AvroProducer(AvroProducerConf, default_value_schema = value_schema)

while True:
    avroProducer.produce(topic = 'my_topic', value = {['Object'][0] : "value", ['Object'] [1] : "true", ['DataStructureType'] : "testvalue", ['ProjectID'] : "123"})

    avroProducer.flush()

1 Ответ

1 голос
/ 02 апреля 2020

Не ясно, что вы ожидаете от чего-то подобного ... ['Object'][0] и ключи dict не могут быть списками.

Попробуйте отправить это, что соответствует вашей схеме Avro 

value = {
    'Object': {
       "Number_ID", 1, 
       "Accept": true
    }, 
    'DataStructureType' : "testvalue", 
    'ProjectID' : "123"
}
...