mariecziek
Siema mirki.
poproszę o gotowe rozwiązanie albo link do materiału z którego mógłbym skorzystać. Mam następujący problem:
Jest aplikacja napisana w #php #symfony która to publikuje eventy w kolejce #rabbitmq. Są też 2 consumery, które to konsumują te eventy. Problem jest taki, że w pewnym miejscu mam race condition. Są opublikowane rożne eventy, które podczas konsumpcji tworzą lub aktualizują rekord w bazie danych. Problem jest w
0
  • Najlepsze
  • Wszystkie komentarze
zakopiak
zakopiak
@mariecziek: Ciężko powiedzieć czego potrzebujesz, ale zgadując na podstawie tego co napisałeś, to nie istnieje żadne gotowe rozwiązanie pod twój problem, bo to twój kod jest problemem. Potrzebujesz po prostu poprawnego designu i tyle.
Na race condition aktualizacji może pomóc transakcja + SELECT FOR UPDATE, żeby zrobić locka na wierszu dopóki nie skończysz swojej operacji update'u.
Co do race condition przy tworzeniu wierszy, to już musiałbyś dokładnie napisać co
4
zakopiak
zakopiak
@mariecziek: Tak jak mówiłem - design kodu. Sterowanie logiką biznesową przez wyjątki to pierwszy klasyczny błąd. Tracisz przez to możliwość zrobienia tej operacji atomowo, jak zresztą widać.
Zamiast tego zrób albo tak jak pisałem - transakcja, select for update, update/insert, koniec transakcji. Albo jeśli jesteś w stanie to zrobić w sposób idempotentny to po prostu INSERT ... ON DUPLICATE KEY UPDATE albo REPLACE.

Ewentualnie zapytaj po prostu jakiegoś seniora
4
Ernest_
Ernest_
#kbin szybki update (tag do czarnolistowania)

https://karab.in

- poprawiona strona wyszukiwania
- poprawiona strona tagu
2
  • Najlepsze
  • Wszystkie komentarze
Rougelord
@Ernest_: w jaki sposób ten fedi wykop jest zabezpieczony przed manipulacja i multikontami, wykopywaniem samemu siebie z innych kont? Jak korpo się dowie to boty to tak zasraja że szkoda gadać, istnieje tam jakieś w twoim panelu fyrdumdyrdum do wyłapywania synchronicznego wykopywania? I kiedy Toto będzie embedowac YouTube i inne żeby nie przenosiło do filmu tylko od razu pokazywało?
0
mariecziek
Siema #php świry.
Mam pytanko do osób pracujących z #symfony i #rabbitmq #amqp - https://symfony.com/doc/current/messenger.html#multiple-failed-transports

No więc mam w aplikacji 2 kolejki - jedna służy do obsługi eventów z części legacy aplikacji - przesyłam event jako JSON. Druga kolejka służy do obsługi eventów z nowej aplikacji. Problem jaki próbuję rozwiązać, to utrata wiadomości w razie coś pójdzie nie tak. Teraz po prostu tracę wiadomość i tyle
1
sophisticated7
Hello, jest tu jakiś magik od RabbitMQ?

Korzystajac z docker-compose postawiłem Rabbita na dwoch klastrach (3 nody per cluster). Teraz chce dodac federacje, na jedenym z clustrow federation ma status running. Na drugim clustrze jest
"Error detail: econnrefused"

version: '3.8'
0
Native856
#rabbitmq #freebsd #mydevil #unix #erlang

Witam, jest moze ktos komu udalo sie uruchomić RabbitMQ na hosingu mydevil? Wiem ze on jest wgrany globalnie. Dostępu do roota nie mam. A dowiedzialem sie tylko tyle, ze trzeba uruchomic go z flaga gdzie wskażę wlasny rabbitmq.conf a w nim sciezke do bazy.
0
  • Najlepsze
  • Wszystkie komentarze
t.....o
t.....o
@Native856: bez roota ni ma rabbiuta
0
Native856
@takiego: Ci od administracji twierdzą, ze sie da
0
tempname0626
Czy ktoś tutaj konfigurował może STOMP w #springboot #java z #rabbitmq jako relay brokerem i działa mu to w więcej niż jednej instancji? Jeśli tak to dajta znać, chciałbym dowiedzieć się co źle robię :D
#programowanie
0
Generyczny_nick
Generyczny_nick
Treść przeznaczona dla osób powyżej 18 roku życia...
0
  • Najlepsze
  • Wszystkie komentarze
Radaka
Potrzebuje w rabbitmq ustawić konsumpcje kolejek tak aby zachowywały się synchronicznie, czyli pobierały kolejną wiadomość gdy proces zakończy przetwarzanie poprzedniej da się to jakoś zrobić ?

#nodejs #javascript #rabbitmq #node
1
  • Najlepsze
  • Wszystkie komentarze
wojtek656
Jest jakis szybki sposob na usuniecie duplikatow z klejki rabbitmq? Mam tylko tam ID w messages. Czy musze najlepac consumera co pobierze wszystko, wywali duplikaty i wysle jeszcze raz do kolejki? #programowaniee #php #rabbitmq
0
  • Najlepsze
  • Wszystkie komentarze
lpelikan
lpelikan
#prasowkadev 30 sierpnia 2019 roku

#javascript i jego dziwactwa
https://dev.to/ben/what-is-the-oddest-javascript-behavior-4dh2

Wprowadzenie do architektury sterowanej zdarzeniami z użyciem #rabbitmq #naukaprogramowania
13
D.....x
D.....x
Czołem!

Mam problemem z ustawieniem połączenia z rabbtmq. Jego IP i port ustawione przez Dockera wynosi 192.168.99.100:32777

teraz w pythonie za pomocą biblioteki tera wykonuję niniejsze polecenia:
parameters = pika.URLParameters('amqp://guest:guest@192.168.99.100:32777/')
2
  • Najlepsze
  • Wszystkie komentarze
svs_svs
svs_svs
Mireczki potrzebuje pomocy z konfiguracją #celery #rabbitmq #supervisor #django #python
Miałem sobie na serwerze jedną apkę w #django z taskami #celery na #rabbitmq, celery odpalane przez #supervisor i wszystko działało jak należy. Dołożyłem kolejną apkę w django zachowując ten sam schemat konfiguracji i działa, tylko zaczęły się problemy. Taski z jednej trafiają czasem do
1
  • Najlepsze
  • Wszystkie komentarze
qwelukasz
#rabbitmq #programowanie

https://i.imgur.com/7qufKef.png

dlaczego to nie chce działać? wydaje mi się, że ten routing jest poprawny a mimo to nie mogę tego opublikować
1
  • Najlepsze
  • Wszystkie komentarze
pepepanpatryk
Mirki korzysta ktoś z #rabbitmq?

Załóżmy, że mam dwa serwisy: Api, oraz Users.Service.
- klient wysyła do Api request celem zarejestrowania się w systemie.
- api wrzuca komendę na szynę, a ona następnie trafia do odpowiedniego serwisu(Uses.Service).
1
  • Najlepsze
  • Wszystkie komentarze
i.....y
i.....y
#docker #rabbitmq #programowanie Chłopacy, pytanie. Mam sobie Dockerfile zaczynający się FROM php:7-apache. Próbuję do #php dodać wsparcie rabbita. Teoretycznie można to zrobić tak RUN apt-get update && apt-get install -y librabbitmq-dev && echo "" | pecl install amqp, ale nic z tego. W php mam Fatal error: Uncaught Error: Class 'PhpAmqpLib\Connection\AMQPStreamConnection' not found. Dodawał może ktoś ten moduł?
4
  • Najlepsze
  • Wszystkie komentarze