多线程使其运行一次

Question

我非常感谢每个为我的第一个问题做出贡献的人，尽管我不以某种方式询问您会忍受我。

我有一个数据库，其中一个表名称合同是合同和组中的数据库，即每个组都有一个合同。

我需要帮助，以便一旦启动机器人，它就会检查数据库和合同列表，然后同时为每个组和他们自己的合同运行任务... 下面的代码是我能够进行的，但它仅适用于一个组，

from web3 import Web3
import json,os,sys

import datetime

import requests
from db import *
import telebot


bot = telebot.TeleBot("Telegram bot api will be here")



 
bsc = "https://bsc-dataseed.binance.org/"
web3 = Web3(Web3.HTTPProvider(bsc))




class BuyBot():
    def init(self,token,group):
        self.token = token
        self.group = group
        
    
    def main(self):
        print(f"EVENTS RUNNING FOR {self.token}")
        event_filter = web3.eth.filter({"address": web3.toChecksumAddress((self.token).upper()), "block_identifier": 'pending', })
        
        
        self.log_loop(event_filter, 2)
               
        
           
    def log_loop(self,event_filter, poll_interval):
        try:
            while True:
                for event in event_filter.get_new_entries():
                    self.handle_event(event)
                    break
                time.sleep(poll_interval)
        except Exception as p:
            print(p)
            self.main()
            
    def handle_event(self,event):
        txn = json.loads(Web3.toJSON(event))
        hash = txn['transactionHash']
    
        if len(hash) > 0:
            transaction_recipt = web3.eth.wait_for_transaction_receipt(hash)
            trs = web3.toHex(transaction_recipt['transactionHash'])
            usl_hash = f"https://bscscan.com/tx/{trs}"
            bot.send_message(self.group,url_hash)


def main():
    while True:
        print("am here")
        con = bot_db()
        mc= con.cursor()
        mc.execute('SELECT * FROM Contracts')
        rows = mc.fetchall()
        for all in rows:
            group = all[1]
            ca = all[0]
            
            check_ = BuyBot(ca,group)
            check_.main()

bot.polling(none_stop=True)

if name == "main":
    try:
        print("Started")
        main()
    except Exception:
        print("rebooted")
        main()

请帮助我需要它来聆听每个小组在每个小组合同的同时聆听BSC链Web3上的事件。

如下所述，如果您不明白我的意思，请忍受我

Answer 1

能够完成我需要的多处理完成我需要的工作。

这是文档

https： > https：> https：> https： //docs.python.org/3/library/multiprocessing.html