Chcę skonfigurować system pub/sub event, ale także powinien być w stanie wykonywać zadania asynchronicznie. Próbowałem zmusić selera do ciężkiego podnoszenia, ale czuję, że próbuję podarować całą masę rzeczy, żeby to działało.Seler jako sieciowe zdarzenia pub/sub
Mam dwie maszyny (wejście i wyjście) i oba mają dostęp do RabbitMQ. Chciałbym mieć program główny uruchamiający pętlę, która czeka na wejście (ruch wykrywany przez kamerę internetową). Mam to ustawione, że input_machine uruchamia main.py, która uruchamia zadanie selera, które jest monitorowane przez robotnik na podrzędnej input_machine do kolejki "input". To zadanie działa tylko przez chwilę, dopóki nie zostanie wykryte jakieś wejście, które następnie wywołuje inny nazwany ('project.entered_room', który nic nie robi) zadanie selera do "wyjściowej" kolejki.
Tymczasem na output_machine, mam instancję selera obserwującą "wyjściową" kolejkę z zadaniem o nazwie ("project.entered_room", która odpowiada na osobę wchodzącą do pokoju).
Tak więc po wykryciu wejścia na maszynie input_machine, zadanie uruchamia się na maszynie wyjściowej. Mogę to zrobić, ale mam dużo problemów z importowaniem i inne bóle głowy. Czy istnieje łatwiejszy sposób, aby to osiągnąć? Czy wszystko się zgadza? Czy używam niewłaściwych narzędzi?
Zajrzałem do wielu różnych struktur, w tym obwodów i skręconych. Skręcony jest bardzo złożony i wydaje mi się, że uderzałbym w gwoździe z młotem pneumatycznym.