Telegram sebagai gudang data untuk proyek-proyek TI

  #      click     if data is not None: if message.text == '': sql = "UPDATE users SET click = {} WHERE chatid = {}".format(data[2]+1,message.chat.id) cursor.execute(sql) conn.commit() await bot.send_message(message.chat.id, ': {} '.format(data[2]+1)) #        10 if message.text == '': sql = "SELECT * FROM users ORDER BY click DESC LIMIT 15" cursor.execute(sql) newlist = cursor.fetchall() # or use fetchone() sql_count = "SELECT COUNT(chatid) FROM users" cursor.execute(sql_count) count=cursor.fetchone() rating=': {}\n'.format(count[0]) i=1 for user in newlist: rating=rating+str(i)+': '+user[1]+' - '+str(user[2])+'\n' i+=1 await bot.send_message(message.chat.id, rating) else: await bot.send_message(message.chat.id, '  ') 

Mari kita menulis logika untuk pendaftaran pengguna

 sql_select = "SELECT * FROM users where chatid={}".format(message.chat.id) sql_insert = "INSERT INTO users VALUES ({}, '{}', {},{})".format(message.chat.id,message.chat.first_name, 0, 0) try: cursor.execute(sql_select) data = cursor.fetchone() if data is None: cursor.execute(sql_insert) conn.commit() await save_data() except Exception: data = await get_data() cursor.execute("CREATE TABLE users (chatid INTEGER , name TEXT, click INTEGER, state INTEGER)") cursor.executemany("INSERT INTO users VALUES (?,?,?,?)", data) conn.commit() cursor.execute(sql_select) data = cursor.fetchone() if data is None: cursor.execute(sql_insert) conn.commit() await save_data() #   button = KeyboardButton('') button2 = KeyboardButton('') #  kb = ReplyKeyboardMarkup(resize_keyboard=True).add(button).add(button2) #     await bot.send_message(message.chat.id,' {}'.format(message.chat.first_name),reply_markup=kb) 

Menyimpan dan mengambil data dari server Telergam

  #-------------------- ------------------------- async def save_data(): sql = "SELECT * FROM users " cursor.execute(sql) data = cursor.fetchall() # or use fetchone() try: #     str_data=json.dumps(data) #      await bot.edit_message_media(InputMediaDocument(io.StringIO(str_data)), admin_id, config_id) except Exception as ex: print(ex) 

 # #-------------------- ------------------------- async def get_data(): #         forward_data = await bot.forward_message(admin_id, admin_id, config_id) #    ,   file_data = await bot.get_file(forward_data.document.file_id) #    url file_url_data = bot.get_file_url(file_data.file_path) #     json_file= urlopen(file_url_data).read() #    json     return json.loads(json_file) 

 def timer_start(): threading.Timer(30.0, timer_start).start() try: asyncio.run_coroutine_threadsafe(save_data(),bot.loop) except Exception as exc: pass 

 #-------------------- ------------------------- if __name__ == '__main__': timer_start() executor.start_polling(dp, skip_updates=True) 

Jadi kodenya sepertinya sudah beres, di sini ada tautan draft kerja ke github .

Bagaimana cara menjalankannya

1. Unduh proyek dari github. Kami memulai proyek di lingkungan pengembangan apa pun untuk python (Misalnya: PyCharm).
2. Lingkungan pengembangan akan secara otomatis memuat pustaka yang diperlukan dari file persyaratan.
3. Ganti Token dari BotFather di main.py
   
   
4. Kami memulai proyek
5. Dari akun kedua, klik / mulai dan tulis kata "admin"
   
   
   
6. Matikan proyek dan isi admin_id dan config_id di file main.py
7. Kami memulai proyek dan dari akun pengguna kami menekan mulai
   
   
   
8. Untung

Pengujian dan grafik

Pengujian dilakukan pada server heroku dengan karakteristik instance minimal. Jadi, kita dapat mengasumsikan bahwa semua tes dilakukan dalam kondisi yang kurang lebih sama.

Grafik dibuat dari sampel ~ 100 permintaan-jawaban. Dan rata-rata sampel disajikan.

PostgreSQL di Amazon RDS dengan karakteristik minimal digunakan sebagai database pada server pihak ketiga.



Dengan satu juta pengguna, waktu cadangan menjadi masalah.



Ukuran cadangan sepenuhnya tergantung pada model data Anda, dalam kasus saya, dengan satu juta pengguna, file data dengan 21 megabita diperoleh.

Kesimpulan

Metode penyimpanan data ini masuk akal untuk proyek hingga satu juta pengguna. Artinya, untuk prototipe atau startup pribadi, metode ini memiliki hak untuk hidup.

Sebagai hasilnya, kami mendapat clicker mandiri sepenuhnya, tidak tergantung pada basis data jarak jauh.

Berikut adalah proyek yang dijelaskan di atas yang digunakan untuk heroku: @Clicker_fast_bot

Saya juga menerapkan proyek yang lebih kompleks dengan ideologi ini: @Random_friend_bot

Persamaan antara dua orang chatroom dan chatroulette, tetapi hanya di telegram.

Dia mencari dalam radius 100 km dari lawan jenis untuk berkomunikasi dan menyadari obrolan tertutup dengan lawan bicara baru.

Jika ini menarik, saya dapat membuang kode sumber proyek. Juga, jika topik ini relevan, maka pada artikel berikutnya saya dapat menjelaskan pembuatan api Rest tanpa database eksternal. Itu adalah tumpukan Django-sqllite-Telegram.

Saya akan senang atas kritik apa pun, terima kasih atas perhatian Anda!