Jak używać kolby lub butelki z Rabbitmq?

Hej! Jestem dostawcą produktów do kolb i butelek, a dziś opowiem o tym, jak używać kolby lub butelki z Rabbitmq. Jeśli lubisz opracowywanie stron internetowych lub po prostu szukasz sposobów optymalizacji aplikacji, ten post jest dla Ciebie.

Po pierwsze, krótko przedstawmy, czym są kolba, butelka i Rabbitmq. Flask to lekka rama internetowa w Python. Jest bardzo łatwo zacząć i świetnie nadaje się do budowania małych i średnich aplikacji internetowych. Butelka jest również prostą i szybką mikro -ramy dla Pythona. Ma minimalistyczny design, co sprawia, że praca z nią jest dziecinna. Z drugiej strony Rabbitmq jest brokerem wiadomości. Pomaga w różnych częściach aplikacji komunikować się ze sobą, wysyłając i odbierając wiadomości.

Po co łączyć kolbę/butelkę z Rabbitmq?

Dlaczego więc chcesz używać kolby lub butelki z Rabbitmq? Cóż, w prawdziwej światowej aplikacji możesz mieć zadania, które zajął dużo czasu, takie jak wysyłanie dużej liczby wiadomości e -mail lub przetwarzanie dużych zbiorów danych. Jeśli poradzisz sobie z tymi zadaniami bezpośrednio w aplikacji do kolby lub butelek, może to sprawić, że aplikacja internetowa jest powolna lub nawet nie reaguje. Właśnie tam pojawia się Rabbitmq. Możesz odciążyć ten czas - konsumowanie zadań do kolejki wiadomości (RabbitMQ) i pozwolić innym pracownikom obsługiwać je w tle. W ten sposób Twoja aplikacja internetowa może podawać inne żądania bez oczekiwania na długie - uruchamianie zadań do zakończenia.

Konfigurowanie środowiska

Zanim zaczniemy kodować, musimy skonfigurować nasze środowisko. Najpierw upewnij się, że masz zainstalowany Python na swoim komputerze. Następnie możesz zainstalować kolbę lub butelkę idługiBiblioteka (która jest używana do interakcji z Rabbitmq w Python)pypeć.

PIP Instaluj kolbę # lub instaluj butelkę instaluj PIKA PIKA

Jeśli używasz kolby, oto prosty przykład tego, jak zintegrować ją z Rabbitmq. Załóżmy, że mamy aplikację do kolby, która musi wysłać wiadomość do kolejki Rabbitmq, gdy użytkownik złoży żądanie.

Importuj PIKA z kolby Import Flask App = Flask (__ name__) @app.route ('/send_message') def send_message (): connection = pika.blockingConnection (pika.connectionparameters („localHost ')) kanałów = connection.channel () kanał.queue_declare (queue =' mego_peue ')' LABTMQ! channel.basic_publish (exchange = '', routing_key = 'my_queue', body = message) print ("[x] send % r" % message) connection.close () return „Wiadomość wysłana do rabbitmq!” jeśli __name__ == '__main__': app.run (debug = true)

W tym kodzie, gdy użytkownik odwiedza/send_messageTrasa, nasza aplikacja Flask łączy się z lokalnym serwerem RabbitMQ, deklaruje nazwaną kolejkęmy_queuei wysyła do niego wiadomość.

Zobaczmy teraz, jak skonfigurować pracownika do konsumpcji wiadomości z kolejki.

Import PIKA def Callback (CH, Method, właściwości, nadwozie): print ("[x] odebrane % r" % body) Connection = pii.blockingConnection (pika.connectionParameters („localHost ')) kanał = connection.channel () kanał auto_ack = true, on_message_callback = callback) print ('[*] oczekiwanie na wiadomości. Aby wyjść na naciśnięcie ctrl+c') channel.start_consuming ()

Ten skrypt robotnika łączy się z tym samym serwerem Rabbitmq, deklarujemy_queueZnowu i zaczyna z niego konsumować wiadomości. Ilekroć przybywa nowa wiadomość,oddzwonienieFunkcja jest wywoływana, a wiadomość jest drukowana do konsoli.

Jeśli używasz butelki, proces jest dość podobny. Oto prosty przykład butelek:

Zaimportuj Pika z trasy importowej butelki, uruchom @Route ('/send_message') def send_message (): connection = pii.blockingConnection (pika.connectionParameters („localHost ')) kanał = connect.channel () channel.queue_declare (queue =' my_queue ') message =' hello from Bottle! channel.basic_publish (exchange = '', routing_key = 'my_queue', body = message) print ("[x] send % r" % message) connection.close () return „Wiadomość wysłana do rabbitmq!” run (host = „localHost”, port = 8080, debug = true)

Korzyści z naszych produktów kolb i butelek

Jako dostawca mogę powiedzieć, że nasze produkty kolby i butelki, takie jakGarnek do kawy izolowanej stali nierdzewnej, są top - wycięcie. Są one wykonane z materiałów wysokiej jakości, zapewniając trwałość i długoterminowe użycie. Niezależnie od tego, czy jesteś deweloperem, który potrzebuje niezawodnego pojemnika na twoje napoje podczas kodowania, czy firmą poszukującą produktów promocyjnych, nasze produkty są doskonałym wyborem.

Obsługa błędów i najlepsze praktyki

Podczas pracy z kolbą lub butelką i rabbitmq kluczowe jest obsługa błędów. Na przykład, jeśli serwer RabbitMQ jest wyłączony, aplikacja może podnieść wyjątek podczas próby połączenia się z nią. Możesz użyć prób - z wyjątkiem bloków, aby wdzięcznie poradzić sobie z tymi błędami.

Importuj PIKA z kolby Importuj App = Flask (__ name__) @app.route ('/send_message') def send_message (): try: connection = pii.blockingConnection (pika.connectionParameters („localHost ')) kanał = connection.channel () kanał Rabbitmq! ' channel.basic_publish (exchange = '', routing_key = 'my_queue', body = message) print ("[x] send % r" % message) connection.close () return „Wiadomość wysłana do rabbitmq!” Z wyjątkiem pii.exceptions.amqpConnectionError: powrót „Nie udało się połączyć z Rabbitmq!” jeśli __name__ == '__main__': app.run (debug = true)

Kolejną najlepszą praktyką jest prawidłowe zarządzanie połączeniem i kanałem. Pamiętaj, aby zamknąć połączenie po zakończeniu go, aby uniknąć wycieków zasobów.

Skalowanie i wydajność

Jeśli Twoja aplikacja rośnie, może być konieczne skalowanie konfiguracji Rabbitmq. Możesz użyć wielu pracowników do jednoczesnego konsumowania wiadomości z kolejki, co może poprawić ogólną wydajność. Możesz także skonfigurować klaster serwerów Rabbitmq w celu uzyskania wysokiej dostępności.

Wniosek

Korzystanie z kolby lub butelki z RabbitMQ to potężna kombinacja, która może pomóc w tworzeniu bardziej wydajnych i responsywnych aplikacji internetowych. Niezależnie od tego, czy obsługujesz długie zadania, czy po prostu potrzebujesz sposobu komunikacji między różnymi częściami aplikacji, RabbitMQ może być świetnym dodatkiem.

Jeśli interesujesz się naszymi produktami kolb i butelek, chcielibyśmy porozmawiać z tobą. Skontaktuj się z nami, aby uzyskać więcej informacji i rozpocznijmy świetne relacje biznesowe. Jesteśmy tutaj, aby zapewnić Ci najlepsze produkty i usługi.

Odniesienia

• „Flask Web Development” autorstwa Miguela Grinberga
• „Rabbitmq in Action” Alvaro Videla i Jason JW Williams