Android, Ubuntu और Python: इंटरनेट रेडियो रिकॉर्डिंग और ऑन-एयर को स्वचालित करें

पूरे हबर समुदाय को नमस्कार!
रास्ते में निश्चित रूप से कई 'घर' <-> 'काम' रास्ते में अपने Android पृष्ठभूमि से संगीत सुनते हैं। मैं अक्सर अतिरिक्त 10-20 मिनट के लिए पेपी ब्रेक के तहत मेट्रो को भरता हूं। परिचालन बेसिंग की जगह की अगली यात्रा पर, "पहले से ही दोपहर के भोजन में सौ साल पुरानी" पटरियों का आनंद लेते हुए मेरे सिर में एक नोट बनाया गया था कि मैं शाम को संगीत पुस्तकालय को अपडेट करना चाहूंगा। बेशक, कार्य दिवस के भंवर में नोट को सुरक्षित रूप से भुला दिया गया था, और अगली सुबह मैंने फिर से एक हैकनी रिकॉर्ड के साथ निकाल दिया। मैंने इसे थोड़ा सा समझ लिया और निर्णय लिया कि इस प्रक्रिया को स्वचालित करने के लिए आवश्यक होगा ताकि स्वचालन व्यवसाय पर मेरे ईश्वर-हानिकारक प्रभाव को बाहर किया जा सके।
इच्छुक नागरिक - बिल्ली के नीचे स्वागत।

यात्रा के दौरान रणनीति का विकल्प निर्धारित किया गया था, बोर्ड पर उबंटू के साथ एटम पर एक छोटे "काले ताबूत" उर्फ ​​सर्वर का लाभ मेरे निपटान में था। समाधान यह था: एक दानव लड़की ने सर्वर पर इंटरनेट रेडियो की धारा प्रवाहित की, और सांप पर स्क्रिप्ट बाकी सब कुछ करता है: फ़ोल्डर्स में फ़ोल्डर्स को सॉर्ट करता है, प्लेलिस्ट बनाता है, और किसी तरह स्मार्टफोन पर सभी अच्छाई को मिला देता है, अधिमानतः रात में।
सामान्य अवधारणा के बाद, योजना के विशिष्ट कार्यान्वयन का विकल्प था। तो, चलिए शुरू करते हैं:

चेतावनी! सभी वार्तालाप रिकॉर्ड किए गए हैं।

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

अजगर का उपयोग करना

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

सांबा, एफ़टीपी या एसएसएचएफएस

अगला - स्मार्टफोन में सूचना कैसे स्थानांतरित करें? सामान्य तौर पर, चूंकि एंड्रॉइड खुद निक्स का मेगा-नेट * है, इसलिए ट्रांसफर इंटरफेस के विकल्प के साथ कोई समस्या नहीं होनी चाहिए। जल्दी से Google बाज़ार से गुज़रने के बाद, मुझे वह सब कुछ मिला जो Androida के लिए सर्वर भाग के रूप में आवश्यक है। यह पता चला कि सांबा, एसएसएचएफ और मानक एफ़टीपी उपलब्ध हैं। सर्वर से एंड्रॉइड पर कई परीक्षण डाउनलोड के बाद, एफ़टीपी पर 2-3 जीबी ट्रैक बंद हो गए, हालांकि यह एसटीएफ पर काम करने के लिए निश्चित रूप से अधिक सुखद था। लेकिन यह सिर्फ दुर्भाग्य है - या तो मेरा स्मार्ट (एंड्रॉइड एचटीसी एचडी 2 के साथ इंटरचेंज) लोड के साथ सामना नहीं कर सका, या कुंजी हस्तांतरण को कुटिल रूप से लागू किया गया था, या कुछ और, लेकिन एक तथ्य के रूप में, मुझे अभी भी सांबा और एसश दोनों में तलछट थी। समय-समय पर, रिकॉर्डिंग ब्रेक हुआ, विशेष रूप से बड़े संस्करणों (0.7-1Gb से अधिक) पर, चाबियाँ खो गईं, या sshfs उपयोगकर्ता के लिए एक्सेस अधिकार गलत तरीके से जारी किए गए थे। सामान्य तौर पर, स्थिर एफ़टीपी को देखते हुए, चाहे यह डेवलपर्स या मेरे हाथों के लिए एक बग है, मैं निश्चित रूप से बीमार हो गया और आखिरी क्षण बना रहा। एफ़टीपी सर्वर को सर्वर से या अपने स्वयं के अनुसूचक द्वारा फोन पर उठना चाहिए था। किसी भी स्थिति में, एंड्रॉइड में कंसोल से निपटना और सर्वर शुरू करने के लिए एप्लिकेशन को इरादे से गुजरना आवश्यक था। और यहाँ निराशा ने मेरी प्रतीक्षा की - ग्राहकों में से कोई भी (शायद मैं बुरी तरह से देख रहा था?) AndroidManifest.xml के वर्णन में ऐसा कुछ भी नहीं था। यानी एप्लिकेशन लॉन्च करना स्वयं संभव था, लेकिन सर्वर की शुरुआत - अब नहीं। मैं संयोग से भाग्यशाली था कि मैंने अद्भुत FTPServer एप्लिकेशन के कार्यों में ध्यान दिया जैसे कि "चयनित वाई-फाई नेटवर्क से कनेक्ट होने पर एफ़टीपी सर्वर शुरू करना"। अब यह समस्या हल हो गई है।

एंड्रॉयड

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

परिणाम

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

• जाँच की गई: यदि स्ट्रीमप्रिपर चल रहा है और यदि प्रक्रियाओं में इसकी कोई प्रतियां हैं। यदि यह नहीं मिला, तो स्क्रिप्ट ने एक अलग बच्चे की प्रक्रिया को व्यवस्थित किया।
• 'रेडियो नाम - DD.MM.YYYY' प्रारूप में फ़ोल्डरों में डाउनलोड किए गए ट्रैक
• एमपी 3 फ़ाइल के निर्माण के समय के अनुसार एक ही फ़ोल्डर में बनाया गया प्लेलिस्ट * .m3u। यानी वास्तव में, क्रम में वे रेडियो पर लग रहे थे।
• स्थान बचाने के लिए, सर्वर पर पुराने रिकॉर्ड हटा दिए गए हैं (स्क्रिप्ट में सीमा निर्दिष्ट है)
• Android पर हटाई गई पुरानी प्रविष्टियाँ (स्क्रिप्ट में सीमा निर्दिष्ट है)
• Android पर नए जोड़े गए (स्क्रिप्ट में सीमा निर्दिष्ट है)

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

प्रयुक्त "सामग्री":

• Android FTPServer के लिए एफ़टीपी सर्वर
• Android टास्कर के लिए उन्नत टास्क समयबद्धक
• अजगर
• Ubuntu सर्वर 12.04 ऑपरेटिंग सिस्टम
• बोर्ड पर एंड्रॉइड ऑपरेटिंग सिस्टम के साथ एचटीसी एचडी 2 मोबाइल फोन

पुनश्च

सिफारिशों और टिप्पणियों की एक जोड़ी:

• राउटर पर, अपने स्मार्टफ़ोन के लिए मैक पते से लगातार एक फ़ुटप सर्वर आईपी एड्रेस जारी करना बेहतर होता है
• समय-समय पर फोन के फ्लैश कार्ड पर खाली जगह की जांच करें
• औसतन, धारा का एक दिन (128 kbit / s पर) 0.8-1.2 GB लगता है
• हवा के माध्यम से सर्वर से स्मार्टफोन में स्थानांतरण की गति लगभग 2.5-3Mb / s है

नीचे मैं स्क्रिप्ट का पाठ प्रदान करूंगा, सामान्य तौर पर काफी स्पष्टीकरण हैं, यह स्पष्ट होना चाहिए "मक्खी पर।"

#!/usr/bin/python # -*- coding: utf-8 -*- #****************** ******************* #*********************************************************** import os import shutil from datetime import * import time from operator import itemgetter from ftplib import FTP import ftplib import subprocess import commands #*********************************************************** #****************** ******************* #****************** ************************ #*********************************************************** dir_exec = '' # ,         dir_music = '' #,      -(     streamripper) dir_music = os.path.join(dir_exec,dir_music) #    alias_dir = '' #   .  : '  - ..' time_shift = 3 #        time_sync = 4 # ,     time_storage = 30 # ,       server = '192.168.1.126' #FTP server,     login = '' # FTP pass_ftp = ' ' #  FTP port = '2121' # FTP andr_music = '/mnt/sdcard/Music' #   FTP rec_proc = ['streamripper', '  ', '-d', '-D', '%S/%A-%T'] #  streamrippera` #*********************************************************** #****************** ************************ #****************** ************************* #*********************************************************** #***     streamripper (    )      shell` def start_rec(proc_stream): num = commands.getoutput('pidof %s |wc -w' % proc_stream) if int(num) >= 2: os.system('killall ' + proc_stream) num = commands.getoutput('pidof %s |wc -w' % proc_stream) if int(num) == 0: proc = subprocess.Popen([rec_proc[0], rec_proc[1], rec_proc[2], dir_exec, rec_proc[3], rec_proc[4],], stdout=subprocess.PIPE) #***      ftp- def ftp_online(): ftpConnect = FTP() try: ftpConnect.connect(server,port) ftpConnect.login(login, pass_ftp) ftpConnect.quit() ftpConnect.close() enable = 1 except: enable = 0 return enable #***  ,   . def mdir(create_dir): if not os.path.isdir(create_dir): os.makedirs(create_dir) #***           def uniq_date(lst): return reduce(lambda y,z: not (z in y) and y.append(z) or y, lst, []) #***   mp3  def date_mp3(path_dir_music): out_date=[] names = os.listdir(path_dir_music) for name in names: if name.endswith('mp3'): path = os.path.join(path_dir_music,name) mtime = os.path.getmtime(path) - time_shift*60*60 out_date.append(date.fromtimestamp(mtime).strftime('%d.%m.%Y')) return out_date #***  mp3  def name_mp3(path_dir_music): out_name=[] names = os.listdir(path_dir_music) for name in names: if name.endswith('mp3'): out_name.append(name) return out_name #***  .          . def m3u(dir,path): m3u_n_d = [] m3u_n_s = [] m3u_names = name_mp3(path) i=0 for m3u_name in m3u_names: m3u_mtime = os.path.getmtime(os.path.join(path,m3u_name)) - time_shift*60*60 m3u_n_d.append([m3u_name,m3u_mtime]) i=i+1 m3u_n_d = sorted(m3u_n_d, key=itemgetter(1)) w = open(path+'/'+dir+'.m3u','w') w.write('#EXTM3U\n') #EXTM3U   m3U for i in range(i): #w.write('./'+m3u_n_d[i][0]+'\n') #   w.write(m3u_n_d[i][0]+'\n') #   PowerAmp w.close #***       NLST. def ftp_nlst(pwd): log = [] ftpConnect.cwd(pwd) ftpConnect.retrlines('NLST', callback=log.append) return log #***       LIST def ftp_list(pwd): log = [] file_ftp = [] ftpConnect.cwd(pwd) ftpConnect.retrlines('LIST', callback=log.append) files = (line.split(':')[1] for line in log) p = list(files) for name in p: file_ftp.append((name[3:])) return file_ftp #***          def num_day(dir_time): date_ = time.mktime(time.strptime(dir_time.split(' - ')[1],'%d.%m.%Y')) now_ = time.time() day_beet = (now_-date_)/(60*60*24) return int(day_beet) #*********************************************************** #****************** ************************* #****************** ***************************** #*********************************************************** #  start_rec(rec_proc[0]) #         creates_dirs = [] u_dates = uniq_date(date_mp3(dir_music)) j=0 for u_date in u_dates: mdir(os.path.join(dir_exec,alias_dir+u_date)) creates_dirs.append([alias_dir+u_date,os.path.join(dir_exec,alias_dir+u_date)]) j=j+1 #   mp3        out_names = name_mp3(dir_music) for out_name in out_names: path = os.path.join(dir_music,out_name) mtime = os.path.getmtime(path) - time_shift*60*60 out_date_temp = date.fromtimestamp(mtime).strftime('%d.%m.%Y') shutil.move(os.path.join(dir_music,out_name),os.path.join(dir_exec,alias_dir+out_date_temp,out_name)) #      for j in range(j): m3u(creates_dirs[j][0],creates_dirs[j][1]) #     dir_rem_serv = os.listdir(dir_exec) for dir_rem_s in dir_rem_serv: if dir_rem_s[:15] == alias_dir: if num_day(dir_rem_s) > time_storage: shutil.rmtree(os.path.join(dir_exec,dir_rem_s)) #     if ftp_online() == 1: ftpConnect = FTP() ftpConnect.connect(server,port) ftpConnect.login(login, pass_ftp) ftpConnect.cwd(andr_music) #      st = ftpConnect.pwd() #     dir_on_root = ftp_list(st) for dir_rem in dir_on_root: if dir_rem[:15] == alias_dir: if num_day(dir_rem) > time_sync: ftpConnect.cwd(os.path.join(st,dir_rem)) files_rem = ftp_list(os.path.join(st,dir_rem)) for file_rem in files_rem: ftpConnect.delete(file_rem) #      ftpConnect.cwd(st) ftpConnect.rmd(os.path.join(st,dir_rem)) #   ftpConnect.quit() ftpConnect.close() #    dir_names = os.listdir(dir_exec) for dir_name in dir_names: if dir_name[:15] == alias_dir: if num_day(dir_name) <= time_sync and ftp_online() == 1: ftpConnect = FTP() ftpConnect.connect(server,port) ftpConnect.login(login, pass_ftp) ftpConnect.cwd(andr_music) #      st = ftpConnect.pwd() #     dir_on_root = ftp_list(st) if dir_name not in dir_on_root: ftpConnect.mkd(os.path.join(st,dir_name)) ftpConnect.cwd(os.path.join(st,dir_name)) list_files = os.listdir(os.path.join(dir_exec,dir_name)) files_on_dir = ftp_list(os.path.join(st,dir_name)) for file in list_files: st_file = str(os.path.join(dir_exec,dir_name,file)) if file not in files_on_dir: ftpConnect.storbinary('STOR ' + file, open(st_file, 'rb'),1024) if file.endswith('m3u'): ftpConnect.storbinary('STOR ' + file, open(st_file, 'rb'),1024) ftpConnect.quit() ftpConnect.close() #*********************************************************** #****************** ******************************