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

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

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

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

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

8 ответов

64 просмотра

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

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

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

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

Виктор FabulouS
screenshot

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

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

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

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

Добрый день! Удалил все файлы с переменными из проекта, получил Error: release deploy: process resources: error validating adoptable resources: adoption validation failed: re...
Evgheni Mad
2
@aigrychev, @ilya_lesikov добрый день! а поддерживает ли werf helm xxxx или werf bundle xxxx работу с сабчартами через http-прокси? (сработает ли использование HTTP_PROXY/HTTP...
Сергей Голод
4
Привет! Вопрос про werf helm Приложение деплоится через werf helm upgrade --atomic Иногда(все условия для воспроизведения до конца непонятны, но есть версия, что это происходи...
𝓐𝓵͢͢͢𝓮𝔁 C
2
Всем привет. Werf v2.10.5 При удалении релиза вместе с неймспейсом (werf dismiss --namespace namespace_name) Сыпятся ошибки ┌ Waiting for resources elimination: namespaces/rel...
Vitalik Petrov
1
А как подмаунтить каталог если я не буду стапель юзать, а просто Докерфайл?
yoshi kakbudto
3
Всем привет. Сегодня добавили в приложение дополнительный образ nginx, в который докидывается системная статика прям в образ. При деплое бандлами деплоилось 200+ джоб(клиентов...
Владимир Муковоз
6
Добрый день, после перехода с версии 1.2 на 2.10 werf cleanup начал удалять использующиеся теги, и до и после обновления использовались дефолтные политики keepPolicies Подскаж...
Дмитрий
29
Вопросик не совсем werf. Но вдруг мы подскажите воркэраунд или ещё что-нибудь. Могу ли я как-нибудь в моменте деплоя внутри heml рендера получить хэшсумму файла шаблона (./tem...
Alex Подрябинкин
11
Друзья, добрый день. Прошу подсказать с базовым вопросом по использованию CI переменных gitlab в werf.yaml. Хочу в beforeInstall использовать env переменную с токеном. Мне нуж...
Anton Zol
10
Добрый день, подскажите пожалуйста, а как поле project (в werf.yaml) параметризовать ? werf converge —project <APP_NAME> в одном общем репо держим 1 хельм чарт и деплоим с ...
Sulaymon
5
Карта сайта