🏸 📶 👩🏾‍💼 पायथन थिएटर के पोस्टर से लेकर टेलीग्राम बॉट तक। भाग २ ✋ 💸 🤚🏼

हम टिकट की खोज के लिए टेलीग्राम बॉट के विकास की कहानी जारी रखते हैं - हैप्पीटिक्सबॉट, शुरुआत पहले भाग में पाई जा सकती है।

दूसरे में मैं स्वयं बॉट के बारे में बात करूंगा, कोड साझा करूंगा, साथ ही ऐसे विचार भी जो वास्तविकता बनने की संभावना नहीं है। बॉट के निर्माण के समय तक अधिकांश कार्यक्षमता पहले से ही एक स्क्रिप्ट प्रारूप में लिखी गई थी, इसलिए मुख्य कार्य टेलीग्राम-मैसेंजर के माध्यम से उपयोगकर्ता इंटरैक्शन इंटरफ़ेस स्थापित करना था। यह 1 भाग के रूप में इतना boltologically नहीं निकला, इसलिए ध्यान कोड का एक बहुत कुछ है।

स्पॉयलर: हैप्पीटसबॉट विदेशी सर्वर, यह स्थानीय और रूसी चालू करने के लिए दूर नहीं जाता है, लेकिन एक दिन इसे लॉन्च किया जाएगा (मुझे विश्वास है) =)

अद्यतन: बॉट थियेटर जनता के बीच साझा किए जाने के बाद, उन्होंने मीडिया में इसके बारे में लिखा। उपयोगकर्ताओं की बाढ़ तेजी से बढ़ी। खेल के कुछ दिनों के बाद, "इसे तुरंत उठाएं, यह कैसे गिर गया" बॉट ने सर्वर पर उड़ान भरी और कई सुधारों का अनुभव किया। मैं संतुष्ट हूं =)

1. खरोंच से शुरू

चूंकि टेलीग्राम बॉट्स को डिजाइन करने में कोई शब्द नहीं था, इसलिए मुझे मूल लेखों और ट्यूटोरियल के साथ शुरुआत करनी थी, जो नेटवर्क पर बहुत सारे हैं। हाँ, वैसे, उस समय बैक-एंड क्या है, मैंने भी कल्पना की थी)) सबक का यह सेट सबसे जानकारीपूर्ण और लागू हुआ। टेलीग्राम के साथ बातचीत करने वाला मॉड्यूल pyTelegramBotAPI ( github ) था।

सबसे लंबे समय तक सज्जाकारों की विचारधारा का विकास हुआ, उनके बारे में इस लेख में पढ़ें। दो हिस्से हैं और बहुत समझ में आता है।

2. उपयोगकर्ता के साथ बॉट की बातचीत के लिए स्क्रिप्ट। मूल खोज

जैसा कि पहले से ही प्रस्तावना और लेख के पहले भाग में उल्लेख किया गया है, लगभग सभी पार्सिंग कोड तैयार थे। यह खोज पैरामीटर सेट करने की विधि को बदलने के लिए बना रहा। इसके आधार पर, एक बॉट व्यवहार स्क्रिप्ट का निर्माण किया गया था। उपयोगकर्ता के लिए उपलब्ध कमांड निम्न सेट तक सीमित हैं:

/ खोजें - एक नई खोज शुरू करें,
/ रीसेट - खोज पैरामीटर रीसेट करें और एक नया शुरू करें,
/ अंतिम खोज - अंतिम क्वेरी के मापदंडों का उपयोग करके परिणाम लौटाता है ,
/ addURL कीमतों में कमी को ट्रैक करने के लिए हितों में प्रदर्शन URL जोड़ें,
/ checkurl - ब्याज के प्रदर्शन के लिए अद्यतन मूल्य,
/ showurL - सभी URL को रुचियों की सूची में शामिल करें

मूल खोज स्क्रिप्ट / खोज के अनुसार , उपयोगकर्ता एक स्थिति से दूसरी स्थिति में, क्रमिक रूप से फ़िल्टर के लिए आवश्यक डेटा दर्ज करता है। अंतिम पैरामीटर दर्ज करने के बाद - प्रस्तुति का स्थान - पोस्टर को विश्व स्तर पर घोषित शब्दकोशों का उपयोग करके सीधे पार्स किया जाता है, जहां कुंजी उपयोगकर्ता आईडी है, मान दर्ज किए गए खोज पैरामीटर हैं।

उपयोगकर्ता की स्थिति को याद रखने के लिए, उन्हें डेटाबेस में संग्रहीत किया जाता है। इसके साथ काम करने के लिए, वेदिस मॉड्यूल (एक कुंजी-मूल्य डेटाबेस कॉन्फ़िगरेशन, प्रलेखन पढ़ें) और एनम (गणना, विवरण 1 , 2 के साथ काम) का उपयोग किया जाता है।

एक अलग कॉन्फ़िगरेशन फ़ाइल Myconfig.py में, हम बॉट पैरामीटर (टेलीग्राम से प्राप्त अद्वितीय टोकन सहित) सेट करते हैं और उन स्थितियों को सूचीबद्ध करते हैं जो उपयोगकर्ता अंदर हो सकते हैं। वे थोड़ा बाहर आए।

from enum import Enum token = "4225555:AAGmfghjuGOI4sdfsdfs5656sdfsdf_c" # ,   (  ) db_file = "Mydatabase.vdb" class States(Enum): """   Vedis    ,        (str) """ S_START = "0" #    S_ENTER_MONTH = "1" S_ENTER_PRICE = "2" S_ENTER_TYPE = "3" S_ENTER_PLACE = "4" S_ENTER_URL="5" #

नतीजतन, हमें एक से दूसरे में स्थिति संक्रमण की सीधी श्रृंखला मिलती है।

भंडारण के लिए हम Vedis डेटाबेस का उपयोग करते हैं। संदेश भेजने वाले उपयोगकर्ता का प्रारंभ हमेशा message.chat.id के माध्यम से किया जाता है।

Dbwoker.py फ़ाइल का कोड, जो डेटाबेस के साथ सहभागिता का वर्णन करता है

 from vedis import Vedis import Myconfig as config #      def get_current_state(user_id): with Vedis(config.db_file) as db: try: return db[user_id] except KeyError: #  /     return config.States.S_START.value #  -  #       def set_state(user_id, value): with Vedis(config.db_file) as db: try: db[user_id] = value return True except: print('  !') #   -   return False

नीचे एक हैंडलर का एक उदाहरण है जो / खोज कमांड द्वारा सक्रिय है। जैसा कि आप देख सकते हैं, इस उदाहरण में कोई डेटा प्रविष्टि नहीं है - केवल "S_ENTER_MONTH" स्थिति का एक परिवर्तन है। नंबर दर्ज करने पर संदेश को देखने के बाद, उपयोगकर्ता इसमें प्रवेश करता है और एक संदेश भेजता है। स्थिति S_ENTER_MONTH के साथ एक संदेश प्राप्त होने पर, अगला कदम शुरू किया जाता है। इनपुट त्रुटियों के मामले में, स्थिति नहीं बदलती है।

  #   @bot.message_handler(commands=["find"]) def cmd_find(message): state = dbworker.get_current_state(message.chat.id) """    ,         .     .    ,           """ if state == config.States.S_ENTER_MONTH.value: bot.send_message(message.chat.id, "    .   ") elif state == config.States.S_ENTER_PRICE.value: bot.send_message(message.chat.id, "      ,   ") elif state == config.States.S_ENTER_TYPE.value: bot.send_message(message.chat.id, ", -    ,       :( ...") else: #  ""   "0" -   bot.send_message(message.chat.id, "      ") dbworker.set_state(message.chat.id, config.States.S_ENTER_MONTH.value) #

यदि बॉट को S_ENTER_MONTH वाले उपयोगकर्ता से संदेश प्राप्त होता है, तो निम्न हैंडलर लॉन्च किया जाता है। वैचारिक रूप से, यह आधार खोज स्क्रिप्ट के अन्य चरणों में भी होता है।

 @bot.message_handler(func=lambda message: dbworker.get_current_state(message.chat.id) == config.States.S_ENTER_MONTH.value) def user_entering_month(message): if not message.text.isdigit(): bot.send_message(message.chat.id, ",    ") return # 1 num[message.chat.id]=message.text #  if int(num[message.chat.id])>12 or int(num[message.chat.id])<1: bot.send_message(message.chat.id, "     1  12.   ") # 2 return url_list[message.chat.id]=take_url(num[message.chat.id]) #  URL-   if url_list[message.chat.id]==[]: #    bot.send_message(message.chat.id, " ,     .     ") return bot.send_message(message.chat.id, "!      .") dbworker.set_state(message.chat.id, config.States.S_ENTER_PRICE.value) #

मानक खोज के अलावा, दिलचस्प प्रदर्शन को सहेजना संभव है।

3. ट्रैकिंग मूल्य परिवर्तन

उपयोगकर्ता मूल्य ड्रॉप होने पर अलर्ट प्राप्त करने के लिए रुचियों की सूची में URL जोड़ सकता है। हमें याद है कि बुनियादी खोज - S_ENTER_URL में अभी भी हमारे पास एक असूचीबद्ध स्थिति थी।

 @bot.message_handler(commands=["addURL"]) def cmd_add_url(message): bot.send_message(message.chat.id, " url,   .  https://") dbworker.set_state(message.chat.id, config.States.S_ENTER_URL.value) #  @bot.message_handler(func=lambda message: dbworker.get_current_state(message.chat.id) == config.States.S_ENTER_URL.value) def user_entering_URL(message): perf_url=message.text user_id=message.chat.id try: add_new_URL(user_id,perf_url) bot.send_message(message.chat.id, '    !') dbworker.set_state(message.chat.id, config.States.S_START.value) #    except: bot.send_message(message.chat.id, 'URL !    !') dbworker.set_state(message.chat.id, config.States.S_ENTER_URL.value)

सूची को संग्रहीत करने के लिए .csv फ़ाइल का उपयोग करें। इसके साथ बातचीत करने के लिए, आपको कुछ कार्यों की आवश्यकता है - मूल्य परिवर्तनों के सत्यापन के साथ लिखना और पढ़ना। यदि यह बदलता है, तो उपयोगकर्ता को सूचित करें।

  def add_new_URL(user_id,perf_url): WAITING_FILE = "waiting_list.csv" with open(WAITING_FILE, "a", newline="") as file: curent_url='https://'+perf_url text=get_text(curent_url) #   1   minPrice, name,date,typ,place=find_lowest(text) user = [str(user_id), perf_url,str(minPrice)] writer = csv.writer(file) writer.writerow(user)

मूल्य अद्यतन फ़ंक्शन कोड थोड़ा लंबा है

 def update_prices(bot): WAITING_FILE = "waiting_list.csv" with open(WAITING_FILE, "r", newline="") as file: reader = csv.reader(file) waitingList=[] for row in reader: waitingList.append(list(row)) L=len(waitingList) lowest={} with open(WAITING_FILE, "w", newline="") as fl: writer = csv.writer(fl) for i in range(L): lowest[waitingList[i][1]]=waitingList[i][2] #   URL  for k in lowest.keys(): text=get_text('https://'+k) minPrice, name,date,typ,place=find_lowest(text) #    1   if minPrice==0: #   minPrice=100000 if int(minPrice)<int(lowest[k]): #   ,    lowest[k]=minPrice #    for i in range(L): if waitingList[i][1]==k: #  -  URL   waitingList[i][2]=str(minPrice) #  bot.send_message(int(gen[i][0]),'   '+k+'    '+str(minPrice)) writer.writerows(waitingList) #     .    ... ...

परिणामस्वरूप, कमांड / चेकुरल द्वारा उपयोगकर्ता इस तरह का परिणाम प्राप्त कर सकता है (अब मैं समझता हूं कि प्रदर्शन का नाम भी प्रदर्शित करना आवश्यक होगा, लेकिन ये श्रृंखला से चीजें "हाथों तक नहीं पहुंची" हैं)।

ठीक है, ठीक है। हम खोज कर सकते हैं, हम ट्रैक कर सकते हैं। कुछ दोस्तों ने बॉट का उपयोग करना शुरू किया, मैं यह पता लगाना चाहता था कि वे कौन हैं और वे क्या ढूंढ रहे हैं। यह जानकारी लॉग में लिखना अच्छा है।

4. हम लॉग में गतिविधि और त्रुटियों को लिखते हैं

लॉगिंग मॉड्यूल हमें इसमें मदद करेगा। जानकारी केवल मूल खोज को पूरा करने के चरण में दर्ज की जाती है, हैंडलर में, जिसमें उपयोगकर्ता स्थिति S_ENTER_PLACE से S_START तक जाती है। त्रुटि रिकॉर्डिंग, बदले में, तब होती है जब वे होते हैं।

मैं इस बारे में बहुत कुछ नहीं कह सकता कि मॉड्यूल कैसे काम करता है, इसलिए बाहर की जानकारी को चालू करना बेहतर है।

लकड़हारा विवरण

 def save_logs(str): loggerInfo.info(str) #    logging.basicConfig(format = u'%(levelname)-8s [%(asctime)s] %(message)s', level = logging.ERROR, filename = u'loggerErrors.log') global loggerInfo loggerInfo = logging.getLogger(__name__) loggerInfo.setLevel(logging.INFO) handler = logging.FileHandler('loggerUsers.log') handler.setLevel(logging.INFO) formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s') handler.setFormatter(formatter) loggerInfo.addHandler(handler) log = logging.getLogger("ex")

डिस्कनेक्ट किए गए कनेक्शन के कारण, बॉट समय-समय पर दुर्घटनाग्रस्त हो जाती है, इसलिए इंटरनेट कनेक्शन त्रुटि पकड़ी गई और 10 सेकंड के बाद बॉट स्वचालित रूप से फिर से चालू हो गया। लेकिन यह हमेशा नहीं बचा, इसलिए मैंने टीमव्यूअर को चालू रखा, ताकि यदि आवश्यक हो तो इसे बढ़ा सके।

5. अनारक्षित

हमें एक बॉट मिला जो स्क्रिप्ट की कार्यक्षमता को बदल देता है, लेकिन आपको मैसेंजर के अंदर एक सुविधाजनक रूप में जानकारी प्राप्त करने की अनुमति देता है। उसने मेरी बुनियादी जरूरतों को बंद कर दिया।

मॉड्यूल और राइटिंग हैंडलर के साथ डिस्क्रैक्शन वीकेंड पर और कभी-कभी शाम को काम के मोड में लगभग एक महीने तक चलता है। इस अवधि के अंत में, ब्याज फीका पड़ने लगा और कार्यक्षमता शुरुआती बिंदु पर अटक गई। Webhook-ahs पर काम करने के सिद्धांतों के माध्यम से तोड़ना संभव नहीं था, और फिर टेलीग्राम अवरुद्ध हो गया था। इससे पहले, एक काम करने वाले सर्वर को बैक-एंड खींचने की योजना थी, लेकिन ... वीपीएन को इस के लिए नहीं रखा जाएगा =)

यहाँ योजनाओं में रहता है, जिनमें से कुछ को एक बार गर्मियों में / सर्दियों की शाम को महसूस किया जा सकता है:

उपयोगकर्ताओं के एक बड़े प्रवाह के साथ लोड परीक्षण। यह अभी तक स्पष्ट नहीं है कि क्या बॉट दृढ़ता से काम करेगा और उपयोगकर्ताओं को भ्रमित नहीं करेगा;
कलाकार के कार्यक्रम में एक नए प्रदर्शन की उपस्थिति की सूचना मेरे पास कई पसंदीदा "सफेद खरगोश" हैं, मैं हर किसी पर नज़र नहीं रख सकता (लेकिन मैं चाहूंगा);
एक निश्चित श्रेणी के टिकटों की बिक्री पर उपस्थिति की अधिसूचना। एक परिचित था, स्टालों की पहली पंक्ति का एक शौकिया, जिसे मैन्युअल रूप से पकड़ना मुश्किल था;
टाइमर द्वारा मूल्य में कमी के लिए ब्याज की यूआरएल की नियमित स्वचालित जाँच। अब यह कमांड पर किया जाता है, टाइमर को जल्दी से सेट नहीं किया जा सकता है, इसलिए इसे एक सरल तरीके से छोड़ दिया गया था;
प्रदर्शनों की यात्राओं के अपने इतिहास का संरक्षण। कहीं .csv फ़ाइल, दिनांक-नाम-रेखा-अप-ऑफ-आर्टिस्ट-आपकी टिप्पणी ताकि खोना न हो;
टिकट की एक श्रेणी के लिए खोज। न केवल कीमत निर्धारित करें, बल्कि सेक्टर (भूतल, आदि) भी;
ऐलिस के लिए एक कौशल में सब कुछ स्थानांतरण। क्यों नहीं?
एक ही कार्यक्षमता के साथ एक मोबाइल एप्लिकेशन बनाएं। क्यों नहीं?

बोल्शोई थिएटर में एक कॉल आया। नूर्येव के टिकटों को पकड़ने के लिए, लेकिन मैं दो शामों में html पोस्टर नहीं उठा सकता था, इसलिए इसे अवास्तविकों की सूची से हटा दिया गया।

फैसले

आलस्य प्रगति का इंजन था, और इसने उसे रोक दिया। बॉट को तीसरे पक्ष के सर्वर पर अपलोड करने के लिए चीजें नहीं आईं, फिर भी, इसके लिए वेब के क्षेत्र में व्यापक दक्षताओं और ज्ञान की आवश्यकता है। परियोजना दिलचस्प बन गई और हमें थोड़ा बेहतर पायथन सीखने की अनुमति दी, इसके एक और पहलू को देखें (सामान्य मशीन सीखने के अलावा), और एक सौदेबाजी कीमत पर थिएटर में कई अद्भुत शामें भी प्रस्तुत कीं। इसके लिए उन्हें धन्यवाद, उन्होंने धमाके के साथ कार्यों को बंद कर दिया।

कोई फर्क नहीं पड़ता कि मैंने कैसे कोशिश की, लेख को अभी भी बहुत सारे कोड और थोड़ा पाठ मिला। मुझे कमेंट में बताई गई असंगत या कम व्याख्या करने में खुशी होगी =)