Как подключиться к основному Flask APP с удаленного сервера - PullRequest
Новая
       4

Как подключиться к основному Flask APP с удаленного сервера

0 голосов
/ 09 апреля 2020 
 import psutil

STATS_URL = ' http://172.20.10.2:8080/report'
SERVER_NAME="test_local_server"

def get_health(): 

    print('generating health report')

    cpu_percent = psutil.cpu_percent(interval=2.0)
    ctime = psutil.cpu_times()
    disk_usage = psutil.disk_usage("/")
    net_io_counters = psutil.net_io_counters()
    virtual_memory = psutil.virtual_memory()    

    # The keys in this dict should match the db cols
    report = dict (
        USER_NAME="USER",
        SERVER_NAME="Test_Server",
        cpupercent = cpu_percent,
        cpu_total = ctime.user + ctime.system,
        free_Percnt=((disk_usage.free/disk_usage.used)*100),
        bytes_sent = net_io_counters.bytes_sent,
        bytes_received = net_io_counters.bytes_recv,
        packets_sent = net_io_counters.packets_sent,
        packets_received = net_io_counters.packets_recv,
        memory_Free = virtual_memory.free,
        )

    return report

if __name__=='__main__':


    print(f'starting health report stream for server :\t{SERVER_NAME}')

    while True:
        report = get_health()
        r = requests.post(STATS_URL, json=report)
        time.sleep(20)

Мне нужно отправить значения этого сценария на удаленном сервере AWS обратно на мое Flask приложение, которое является моим основным сервером на моем windows ноутбуке. 

@app.route("/report",methods=['POST'])
def report():
    if request.method=='POST':
        time_epoch=time.time()
        incoming_report = request.get_json()
        print("Generating Health report")
        username=incoming_report["USER_NAME"]
        server_name=incoming_report["SERVER_NAME"]
        disk_free=incoming_report["free_Percnt"]
        bytes_sent=incoming_report["bytes_sent"]
        bytes_received=incoming_report["bytes_received"]
        packets_sent=incoming_report["packets_sent"]
        packets_received=incoming_report["packets_received"]
        memory_free=incoming_report["memory_Free"]
        cpu_percent=incoming_report["cpupercent"]
        cpu_total=incoming_report["cpu_total"]
        conn=sqlite3.connect("Health.db")
        conn.execute(f"create table if not exists {username}_{server_name} 
 (HEALTH_ID integer primary key AUTOINCREMENT,Time_Epoch integer,Disk_Free varchar(80),Bytes_Sent varchar(80),Bytes_Received varchar(80),Packets_Sent varchar(80),Packets_Received varchar(80),Memory_Free varchar(80),Cpu_Usage_Percent varchar(80),Cpu_Time varchar(80));")
        conn.execute(f'insert into {username}_{server_name} (Time_Epoch,Disk_Free,Bytes_Sent,Bytes_Received,Packets_Sent,Packets_Received,Memory_Free,Cpu_Usage_Percent,Cpu_Time) values {time_epoch,disk_free,bytes_sent,bytes_received,packets_sent,packets_received,memory_free,cpu_percent,cpu_total}')
        conn.commit()
        return {'message': 'success'}



if __name__ ==("__main__"):
    app.run(host='0.0.0.0',port=8080)

Итак, я изменил хост на «0.0.0.0», потому что, когда я проверил онлайн, я обнаружил, что приложение flask публикует c, но соединение из скрипта говорит, что время соединения истекло. Может кто-то помочь мне отправить значения из скрипта python обратно в мое приложение flask?

1 Ответ

0 голосов
/ 09 апреля 2020

Вам нужно перенаправить порт 8080 на вашем роутере. Прямо сейчас ваш домашний маршрутизатор также является брандмауэром и не позволяет ничего инициировать соединение с компьютером локальной сети (ваш P C). Необходимо сказать: «если кто-то пытается подключиться к нашему домашнему IP-адресу через порт 8080, подключите его к моему P C по внутреннему IP-адресу xxxx»

...