Дедофорум Z
     
powered by simpleCommunicator - 2.0.59     © 2025 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Скриптовые языки программирования [закрыт для гостей] / Вялые питоны
Модераторы: Ихтиандр
6 сообщений из 6, страница 1 из 1
Вялые питоны
    #394983
Ихтиандр
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ихтиандр
Модератор темы
А вот скажите мне петончики
создаю экземпляр класса для работы с кафкой

пока не задумывался над обработкой ошибок - все работало.
однако ведь не исключено что в топик попало говно не по ожидаемому формату
стал париться обработкой эксепшенов...

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

трай на сабскрайб прописал - вроде прожевало

Задумка теперь ломать цикл считывания брэйком при ошибке декодирования JSON и посылать обратно на подписку

Где тепарь ловить ValueError при декодировании считываемых сообщений, то есть при обращении к message["FieldName"].value?
в каком месте кода писать try: except?

Пробую так:
Код: Python
1.
2.
3.
4.
5.
6.
7.
    for message in consumer:
      try:
        print ("%s" % (message.value["DateTime"]))
        ...
      except ValueError as vErr:
        print_error("Exception during read/decode JSON from Kafka - {}".format(vErr))
        break
Не обрабатывается эксепшен, вываливается на строке с обращением.
...
Ихтиандр:
Пользователь запросил модераторские права на тему.
Рейтинг: 0 / 0
15.05.2023, 14:25
| Ответить | Цитировать | Написать | Ответы  
Вялые питоны
    #395113
IT-Клоп
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
IT-КлопПривилегированный пользователь
Участник
А если так - то какая ошибка?
Код: Python
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
    for message in consumer:
      try:
        print ("%s" % (message.value["DateTime"]))
        ...
      except ValueError as vErr:
        print_error("Exception during read/decode JSON from Kafka - {}".format(vErr))
        break
      except Exception as e:
        print("Exception is {}",format(e))
        break
...
Рейтинг: 0 / 0
15.05.2023, 15:26
| Ответить | Цитировать | Написать  
Администратор:
Пользователь назначен модератором темы: Ихтиандр.
Вялые питоны
    #396654
Ихтиандр
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ихтиандр
Модератор темы
Да вроде ловится except (ValueError, KeyError,TypeError) as ve
Хотел еще обрабатывать ошибки кафки, если там обрыв случится.
Пытаюсь except KafkaEror писать - пишет что не описан KafkaError

В чем дело может быть?
...
Рейтинг: 0 / 0
16.05.2023, 16:26
| Ответить | Цитировать | Написать | Ответы  
Вялые питоны
    #397121
Кусь
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Кусь
Участник
Ихтиандр  15.05.2023, 14:25
[игнорируется]
394983
однако ведь не исключено что в топик попало говно не по ожидаемому формату
На этот случай надо использовать Schema Registry и JsonSerializer, а не твой самопал с перехватом в Exception.
Ихтиандр  15.05.2023, 14:25
[игнорируется]
394983
Где тепарь ловить ValueError
С чего ты взял, что тебе надо ловить только ValueError, а не другие ошибки (например JSONDecodeError), которые у твоём коде просто не перехватываются?
...
Рейтинг: 0 / 0
16.05.2023, 22:44
| Ответить | Цитировать | Написать  
Вялые питоны
    #397125
Кусь
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Кусь
Участник
Ихтиандр  16.05.2023, 16:26
[игнорируется]
396654
Хотел еще обрабатывать ошибки кафки, если там обрыв случится.
Обрыв чего? У тебя консюмер посылает регулярно heartbeat на Kafka кластер. Попробуй запустить консюмер, потом останови кластер при работающем консюмере и посмотри какую ошибку кидает твой питонячий консюмер. Её и перехватывай потом
...
Изменено: 16.05.2023, 22:54 - Кусь
Рейтинг: 0 / 0
16.05.2023, 22:53
| Ответить | Цитировать | Написать  
6 сообщений из 6, страница 1 из 1
Форумы / Скриптовые языки программирования [закрыт для гостей] / Вялые питоны
Модераторы: Ихтиандр
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
ReSQL.ru       Кролег: Проекты, Новости, Чат       Пашэ: Рисунки, Танки, Чат       Деда: Фотоальбом, Встречи       Чоткий форум
Закрыть
start [/forum/topic.php?fid=25&tid=9623]:
 0ms
get settings:
 9ms
get forum list:
 12ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 43ms
get topic data:
 11ms
get forum data:
 3ms
get page messages:
 99ms
get tp. blocked users:
 2ms
others: 27ms
total:  212ms
созд. / загр.: 212ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]