Попытка прочитать события из концентратора событий в лазурных блоках данных в python

Question

Я пытаюсь прочитать данные из концентраторов событий.Я отправляю данные из твиттера как json через отправителя событий.Когда я пытаюсь прочитать данные и добавить их в список, я получаю следующую ошибку. Где я, возможно, ошибаюсь?код ниже:

        for tweet in ts.search_tweets_iterable(tso):
            print(tweet)
            sender.send(EventData(tweet))


try:
    receiver = client.add_receiver(CONSUMER_GROUP, PARTITION, prefetch=5000, offset=OFFSET)
    client.run()
    start_time = time.time()
    for event_data in receiver.receive(timeout=100):
        last_offset = event_data.offset
        last_sn = event_data.sequence_number
        messages.append(next(event_data.body))
        total += 1

Я получаю следующую ошибку:

TypeError: объект dict не является итератором

Answer 1

Согласно сообщению об ошибке: TypeError: объект dict не является итератором.

Это означает, что вместо итератора используется тип dict.Вы должны проверить в своем коде, какой тип "dict" вызывает эту ошибку.Затем вы можете использовать функцию iter() для преобразования dict в итератор.