🚶🏿 🎨 ⏯️ टिक टीएसी को पैर की अंगुली, भाग 6: फ्लास्क और अजवाइन / खरगोश 👩🏽‍🔧 👨‍❤️‍👨 🛀🏽

टिक टीएसी को पैर की अंगुली: सामग्री चक्र

आइए Celery / RabbitMQ को हमारी परियोजना से जोड़ने का प्रयास करें। एक आधार के रूप में, फ्लास्क के साथ एक परियोजना लें। अजवाइन यादृच्छिक संख्या गणना करेगा।

परियोजना स्थापना

हम आपके कंप्यूटर पर प्रोजेक्ट क्लोन करते हैं:

git clone https://github.com/nomhoi/tic-tac-toe-part6.git

कंटेनर लॉन्च करें:

 cd tic-tac-toe-part6 docker-compose up -d

हम वेब एप्लिकेशन का निर्माण करते हैं:

 cd front npm install npm run-script build

ब्राउज़र को http: // localhost पर खोलें।

डॉकटर कंटेनर

नेगनेक्स सेवा अपरिवर्तित बनी हुई है। फ्लास्क सेवा में, उन्होंने सेलेरी पैकेज इंस्टॉलेशन को आवश्यकताओं के साथ जोड़ा। फ़ाइल को सेलेरी प्रोजेक्ट स्रोत के साथ फ़ोल्डर में रखा:

  volumes: - ./flask:/code - ./celery/app/proj:/code/proj

नई अजवाइन और खरगोश सेवाओं को जोड़ा गया है ।

  celery: container_name: celery build: context: celery/ dockerfile: Dockerfile volumes: - ./celery/app:/app depends_on: - rabbit networks: - backend rabbit: container_name: rabbit hostname: rabbit image: rabbitmq:3.7.15-alpine environment: - RABBITMQ_DEFAULT_USER=admin - RABBITMQ_DEFAULT_PASS=CT2gNABH8eJ9yVh ports: - "5672:5672" networks: - backend

अजवाइन की सेवा

अजवाइन सेवा इस ट्यूटोरियल पर आधारित है। जो लोग अजवाइन से परिचित नहीं हैं, यह इस ट्यूटोरियल के माध्यम से यहाँ जाने के लिए समझ में आता है:

 $ docker exec -it celery python Python 3.7.3 (default, May 11 2019, 02:00:41) [GCC 8.3.0] on linux Type "help", "copyright", "credits" or "license" for more information. >>> from proj.tasks import add >>> add.delay(2, 2) <AsyncResult: 43662174-657f-4dd3-ab1a-22f5950c8794> >>>

जैसा कि आप देख सकते हैं, सेलेरी में हमारी परियोजना एक प्रोज पैकेज के रूप में तैयार की गई है। सेलेरी कार्यों में, हमारे getnumber कार्य को कार्यों की फ़ाइल में जोड़ दिया गया है :

 @app.task def getnumber(): return randrange(9)

फ्लास्क सेवा

मुझे आपको याद दिलाना है कि हमने इस सेवा में अजवाइन पैकेज जोड़ा और प्रॉजेक्ट के साथ फ़ोल्डर को माउंट किया। इस परियोजना का स्रोत कोड अब दो सेवाओं, फ्लास्क और अजवाइन में मौजूद है ।

 from flask import Flask, jsonify from proj.tasks import getnumber from proj.celery import app as celery app = Flask(__name__) @app.route('/number') def number(): task = getnumber.delay() return task.id @app.route('/result/<task_id>') def result(task_id): task = getnumber.AsyncResult(task_id) result = task.get(timeout = 3) response = { 'state': task.state, 'number': result, } return jsonify(response)

नंबर हैंडलर में, हम गेटनरी कार्य को कहते हैं, जो कि अजवाइन कार्यकर्ता में चलता है , और कार्य पहचानकर्ता को वापस करता है। परिणामी हैंडलर में, हम पहचानकर्ता द्वारा पूर्ण किए गए कार्य का परिणाम प्राप्त करते हैं और फ्रंट एंड JSON प्रारूप में प्रतिक्रिया लौटाते हैं।

दृश्यपटल

हमारे गेम के प्रबंधक में, यादृच्छिक संख्या बटन पर क्लिक करके, हम पहले पते / नंबर पर बैकएंड पर एक अनुरोध भेजते हैं और उसमें सेलेरी टास्क आईडी प्राप्त करते हैं। उसके बाद, getResult फ़ंक्शन में, हम समय-समय पर पते / परिणाम / <task_id> पर परिणाम प्राप्त करने के लिए बैकएंड पर एक अनुरोध भेजते हैं।

 async function getResult(task_id) { var i = 1; var timerId = setTimeout(async function go() { console.log("Result request: " + i); console.log("Task Id: " + task_id) const res = await fetch(`result/` + task_id); const response = await res.text(); if (res.ok) { let result = JSON.parse(response); console.log(result) if (result.state === 'SUCCESS') { let i = parseInt(result.number); if ($status === 1 || $history.state.squares[i]) { promise_number = result.number + ' - busy'; return; } promise_number = i; history.push(new Command($history.state, i)); return; } } if (i < 5) setTimeout(go, 500); i++; }, 500); }

बैकएंड के लिए प्रश्नों के परिणाम का परिवर्तन

 {#await promise} <p>...</p> {:then taskid} <p>Task Id: {taskid}</p> {:catch error} <p style="color: red">{error.message}</p> {/await} {#await promise_number} <p>...</p> {:then number} <p>Number: {number}</p> {:catch error} <p style="color: red">{error.message}</p> {/await}

घर का पाठ

वास्तव में, अब परिणाम पहले अनुरोध के तुरंत बाद आता है। अजवाइन में रहने वाले हमारे बुद्धिमान एजेंट को थोड़ा विचारशील बनाने की कोशिश करें, ताकि तुरंत जवाब न दें।

समय-समय पर एक त्रुटि फ्लास्क 'ए' 500 (इंटरनल सीरियस एरर) से आने लगती है, यह अपवाद "celery.exception.TimeoutError: उठाता है: ऑपरेशन समय समाप्त हो गया।" अजवाइन में । केवल रीबूटिंग सेवाएँ मदद करती हैं। खुदाई नहीं करते हुए क्या बात है, कृपया देखें।

GetResult केवल SUCCESS स्थिति के साथ प्रतिक्रिया की प्रक्रिया करता है, अन्य मामलों में, एक दूसरा अनुरोध किया जाता है। आप FAILURE और PENDING के साथ प्रतिक्रिया हैंडलिंग जोड़ सकते हैं। परिणाम हैंडलर में प्रतिक्रिया का गठन कार्य की स्थिति पर भी निर्भर हो सकता है।

RabbitMQ संदेश ब्रोकर के बजाय, आप Redis कनेक्ट करने का प्रयास कर सकते हैं।

आप संदेश दलालों के माध्यम से आवेदन से अनुरोधों को निष्पादित करने का प्रयास कर सकते हैं।

और इसे Boost.Beast उदाहरण के आधार पर करने का भी प्रयास करें।

गिटहब भंडार

https://github.com/nomhoi/tic-tac-toe-part6

टिक टीएसी को पैर की अंगुली, भाग 6: फ्लास्क और अजवाइन / खरगोश