0

ルーターがオンになっているポートのスイッチから SNMP 値を読み取り、いくつかの計算を行い、現在の平均帯域幅使用率を返すホーム ネットワーク用の小さなサービスを作成しようとしています。

2秒ごとにsnmp値を読み取るのに十分なpysnmpが動作するようになりました...次に、web.pyを統合して、アップロードとダウンロードの平均をキロビット単位でJSONを返す非常にシンプルなWebサービスを作成することにしました。

これを行うには、スレッドを使用して SNMP ポーリングをバックグラウンドで実行し続ける必要があります。私はNOOOBですが、正しく機能していません.値をブラウザにロードすると、何らかの理由でSNMPプロセスの2番目のスレッドが作成されるようですが、その理由がわかりません.

コードは次のとおりです。

from pysnmp.entity.rfc3413.oneliner import cmdgen
from time import sleep
import threading
import json
import web

LOCK = threading.Lock()

class getBW(threading.Thread):

    def __init__(self):
        threading.Thread.__init__(self)
        self.data = dict(upload="0",download="0",)
        self.lock = LOCK
        self.start()

    def run(self):

        router_ip = "192.168.2.2"
        snmp_community = "public"
        upload_mib = "1.3.6.1.2.1.2.2.1.16.1"
        download_mib = "1.3.6.1.2.1.2.2.1.10.1"
        read_interval = 2
        up_octets = 0
        dn_octets = 0
        last_up_octets = 0
        last_dn_octets = 0
        up_change = 0
        dn_change = 0
        avg_up =0
        avg_dn =0
        up_hist = [0,0,0,0,0] 
        dn_hist = [0,0,0,0,0]
        i = 0
        cmdGen = cmdgen.CommandGenerator()

        while (1):
            errorIndication, errorStatus, errorIndex, varBinds = cmdGen.getCmd(
                cmdgen.CommunityData(snmp_community),
                cmdgen.UdpTransportTarget((router_ip, 161)),
                upload_mib,
                download_mib
            )

            # Check for errors and print out results
            if errorIndication:
                print(errorIndication)
            else:
                if errorStatus:
                    print('%s at %s' % (
                        errorStatus.prettyPrint(),
                        errorIndex and varBinds[int(errorIndex)-1] or '?'
                        )
                    )
                else:
                    for name, val in varBinds:
                        if str(name) == upload_mib:
                            if up_octets > 0: 
                                last_up_octets = up_octets
                                up_change = val-last_up_octets
                                # convert to kilobits/s
                                up_change = (((up_change*8)/1000)/read_interval)
                                up_hist[i] = up_change
                                avg_up=(sum(up_hist)/len(up_hist))
                            up_octets = val
                            #print ('%d kilobit per second upload, %d average' % (up_change,avg_up))

                        elif str(name) == download_mib:
                            if dn_octets > 0:
                                last_dn_octets = dn_octets
                                dn_change = val-last_dn_octets
                                # convert to kilobits/s
                                dn_change = (((dn_change*8)/1000)/read_interval)
                                dn_hist[i] = dn_change
                                avg_dn=(sum(dn_hist)/len(dn_hist))
                                i += 1
                                i = i % 5 # if I is 5 reset to 0
                            dn_octets = val
                            #print ('%d kilobit per second download, %d average' % (dn_change,avg_dn))

            #output values to dict
            self.lock.acquire()
            self.data = dict(upload=str(avg_up),download=str(avg_dn),)
            self.lock.release()
            print("UPLOAD: %d change, %d average; DOWNLOAD: %d change, %d average" % (up_change,avg_up,dn_change,avg_dn))
            print("sleeping for %i secs...\r\n" % read_interval)
            sleep(read_interval)

try:
    BW = getBW()
except:
    print "Error: unable to start thread"

urls = ("/.*", "hello")
app = web.application(urls, globals())

class hello:
    def __init__(self):
        self.lock = LOCK
    def GET(self):
        self.lock.acquire()
        thedata = BW.data
        self.lock.release()
        return json.dumps(thedata)

if __name__ == "__main__":
    #start web service
    app.run()

私は本当にあなたの助けに感謝します. 私はスレッドの完全な初心者であり、Python を学習していることを覚えておいてください。ありがとう！

4

1 に答える 1

1

あなたはweb.pyの組み込みWebサーバーを使用しています。デフォルトでは、「モジュールのリロード」が有効になり、リローダーはメイン モジュールを 2 回ロードします。インポート時にスレッドを開始しているため、2 つのスレッドが実行されます。

簡単な修正は、スレッドの作成を__main__ブロックに移動して、一度だけ作成されるようにすることです。

if __name__ == "__main__":
    BW = getBW()
    #start web service
    app.run()
于 2012-11-20T22:30:08.387 に答える