Всем привет. Настраиваю по гайду ClickHouse + RabbitMQ. У меня

есть таблицы, одна тестовая, другая обычная.
Для проверки работоспособности написал скрипт на python (с использованием pika). Настройки обменников, очередей - в скрипте.

Если я записываю сначала N записей в тестовую таблицу, потом K записей в обычную, то у меня в тестовой таблице могут дублироваться данные, или же добавляться данные, которые вообще я пытался добавить пару часов назад. При этом я чистил очереди, пересоздавал их и обменники. При этом в основную таблицу никогда записи не доходят.(

Обменники и очереди для таблиц разные.

В чем может быть проблема?(

8 ответов

45 просмотров

Во первых реализация поддержки реббита в клике за гранью понимания. Во вторых вы пишете в таблицы, в чем вопросы к реббиту, не понимаю.

Вы бы показывали скриношты чтоли, очень сумбурные высказывания ничем не подкрепленные

Виктор-FabulouS Автор вопроса
Aleksey Barabanov
Вы бы показывали скриношты чтоли, очень сумбурные ...

Скриншоты чего именно? Скрин очереди и обменника для тестовой таблицы, в том числе со старыми данными.

Виктор FabulouS
screenshot

Консьюмеров нет, никто не читает эту очередь

А вот тут есть биндинг на очередь с длиннющим именнм

Похожие вопросы

Обсуждают сегодня

Всем привет! Использую gitlab-ci. Настроил gitlab-agent для деплоя в куб. При деплое проекта в логах такая ошибка: Executing deploy plan failed to watch "ns:my-project/Ingress...
Konstantin Moiseev
4
Всем привет, не нашел в документации как при сборке с buildah сделать запуск команды от другого пользователя (пользователь из базового образа root, а команду надо выполнить из...
Egor Talantsev
3
Коллеги, добрый день, у меня небольшой вопрос: А что дает ключ —env у команды werf bundle apply? Если в werf converge он задавал имя namespace и чарта, то в werf bundle apply ...
Сергей Сухорада
14
Всем привет! Собираю образы при помощь werf export. Также есть стейдж werf cleanup. Я ожидаю, что werf будет сам чистить ранер, но этого не происходит. Я получаю при ручном з...
Макс
5
Добрый день, подскажите как интегрировать данные для авторизации в registry из variables gilab проекта при деплое helm чарта уже в кластере использую шаблон https://ru.werf.i...
Artem S
11
Всем привет! Пытаюсь через werf деплоить оператор Crunchy Postgres - деплой происходит нормально. А вот удаление (werf dismiss) не работает, т.е. команда зависает, вывода ника...
Ⲥⲉⲣⲅⲉύ Ⲗⲁцыⲅυⲏ 🎩
5
Это у всех так или только у меня? Чё происходит?
სერგეი ქრისტოვი
8
А mirror в кубер получилось у кого-нибудь добавить добавить?
Evgheni Mad
7
всем трям! Кто-нибудь работал со связкой werf + harbor + trivy ? Во время сборки образа выходит ошибка "PROJECTPOLICYVIOLATION: current image with "Pending" status of vulnerab...
Авессалом
16
Приветствую! Предположим, что есть некоторое количество разных приложений, например 10, которые собираются через Werf Предположим, что им всем необходим sidecar контейнер, кот...
Alexander Kozharsky
1
Карта сайта