23 похожих чатов

Python Python
DotNetRuChat DotNetRuChat
GNU/Linux Help GNU/Linux Help
Telegram Developers Telegram Developers
Node.js — русскоговорящее... Node.js — русскоговорящее...
DevOps — русскоговорящее ... DevOps — русскоговорящее ...
Django [ru] Django [ru]
Go-go! Go-go!
ntwrk ntwrk
phpGeeks phpGeeks
Kubernetes — русскоговоря... Kubernetes — русскоговоря...
pgsql – PostgreSQL pgsql – PostgreSQL
Laravel Pro Laravel Pro
ClickHouse не тормозит ClickHouse не тормозит
Rust — русскоговорящее со... Rust — русскоговорящее со...
С# С#
pro.jvm pro.jvm
Docker — русскоговорящее ... Docker — русскоговорящее ...
Python beginners Python beginners
Системное администрирован... Системное администрирован...
werf (чат) werf (чат)
Это RabbitMQ Это RabbitMQ
DevSecOps - русскоговорящ... DevSecOps - русскоговорящ...
Это RabbitMQ Это RabbitMQ
Виктор-FabulouS

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

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

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

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

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

#backend #devops #rabbitmq #russian
0

8 ответов

43 просмотра
Aleksey-Barabanov

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

0
3 месяца назад
Aleksey-Barabanov

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

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

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

0
3 месяца назад
Aleksey-Barabanov
Виктор FabulouS
screenshot

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

0
3 месяца назад
Aleksey-Barabanov

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

0
3 месяца назад

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

Это RabbitMQ Это RabbitMQ / Sergey
Подписаться

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

#backend #devops #rabbitmq #russian
23.05.2024
0
3 ответов
Это RabbitMQ Это RabbitMQ / Format
Подписаться

Всем здравствуйте!) У меня такой вопрос. Есть два роута, роут1 и роут2. Они связаны с очередью some_queue. По задаче предполагается, что есть два паблиша. Паблиш1 отправляет...

#backend #devops #rabbitmq #russian
16.05.2024
0
10 ответов
Это RabbitMQ Это RabbitMQ / Юрий
Подписаться

Чем принципиально отличается ack от reject (requeue=false)? Оба же удаляют сообщения из очереди?

#backend #devops #rabbitmq #russian
10.03.2024
0
54 ответов
Это RabbitMQ Это RabbitMQ / Sergey
Подписаться

pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...

#backend #devops #rabbitmq #russian
06.05.2024
0
9 ответов
Это RabbitMQ Это RabbitMQ / Sergey
Подписаться

По хорошему на каждый паблишер и на каждый консюмер создается свой один инстанс BlockingConnection?

#backend #devops #rabbitmq #russian
23.05.2024
0
1 ответов
Это RabbitMQ Это RabbitMQ / Nex1n [CHECK_BIO]
Подписаться
screenshot

Всем привет!Пытаюсь поставить плагин rabbitmq-delayed-message-exchange:latest Ошибка: Feature flags: stream_single_active_consumer: required feature flag not enabled! It must...

#backend #devops #rabbitmq #russian
17.05.2024
0
2 ответов
Это RabbitMQ Это RabbitMQ / Aleksey Barabanov
Подписаться

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

#backend #devops #rabbitmq #russian
02.04.2024
0
25 ответов
Это RabbitMQ Это RabbitMQ / Игорь Самарский
Подписаться

Всем привет! Подскажите, пожалуйста, почему не применяются настройки? Хочу задеплоить вот такой кластер в кубер. apiVersion: rabbitmq.com/v1beta1 kind: RabbitmqCluster metad...

#backend #devops #rabbitmq #russian
24.04.2024
0
1 ответов
Это RabbitMQ Это RabbitMQ / Виктор FabulouS
Подписаться

Может кто подсказать, есть ли какая-то особенность по настройке RabbitMQ + ClickHouse внутри одного композ файла (в общую сеть добавил)? Интересную ошибку ловлю в реббите: 0...

#backend #devops #rabbitmq #russian
10.04.2024
0
5 ответов
Это RabbitMQ Это RabbitMQ / Pepel📰
Подписаться

Всем привет, есть ли возможность как то приоритизировать сообщение в очереди, то есть по сути класть в начало , у нас есть что то что 5, очередь ->1,3,2-> по обычному ->5,1,3...

#backend #devops #rabbitmq #russian
16.05.2024
0
2 ответов
Смотреть еще
Это RabbitMQ Это RabbitMQ
Подписаться
Вопросов 446
Ответов 1141
Участников 938
Telegram @rabbitmq_ru

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

Приветствую еще раз) Появился вопрос, можно ли в kube-run прокинуть ENV переменные из сикрета и/или конфигмапы а еще лучше из values, в примерах видел только из .env, но это ...
Vladislav Antipov
5
Всем привет, все время юзал бандлы, но появилась задача по базовому образу и команда werf build не пушит образ werf build --config='./root/werf.yaml' --repo ${CI_REGISTRY_IMAG...
Илья Корж
4
Всем привет, подскажите, пожалуйста, сколько живет connection к рэббиту, могу ли я использовать один инстанс подключения? Если да, то считается ли это хорошей практикой? Вот п...
Sergey
3
всем трям! Кто-нибудь работал со связкой werf + harbor + trivy ? Во время сборки образа выходит ошибка "PROJECTPOLICYVIOLATION: current image with "Pending" status of vulnerab...
Авессалом
16
Подскажите пожалуйста, почему на mac m1 (arm) не монтируется ssh-agent сокет в собираемый образ? В системе не запущен ssh-agent и переменная среды SSH_AUTH_SOCK не задана. tes...
Eugene Shutov
6
Спасибо, для интеграционных тестов тогда лучше субчарт и в нем jobs создавать, которые по пробе запускаются при вызове coverage?
Vladislav Antipov
1
У меня вот такая ситуация. Хочу собирать кастомизированный образ postgres, но катить его чарт bitnami/postgresql. В .helm/Chart.yaml моего проекта добавлен зависимый чарт bitn...
Ilya Kanyukov
2
Всем здравствуйте!) У меня такой вопрос. Есть два роута, роут1 и роут2. Они связаны с очередью some_queue. По задаче предполагается, что есть два паблиша. Паблиш1 отправляет...
Format
10
Всем, привет Есть задача использовать публичные helm чарты и добавлять к ним свои изменения отдельным файлом. Это позволит легко обновляться при выходе новой версии чарта, та...
Andrey Asoskov
1
А если для werf организовать отдельный репозиторий, а сервисы из проекта подключить как симлинки? И симлинки в гитигнор добавить?
Dmitriy Andreev
13
Карта сайта