Черновик асинхронного GET/POST для micropython

# async http
import uasyncio as asyncio
import network
import ping
import time
try:
    import usocket as socket
except:
    import socket
station = network.WLAN(network.STA_IF)

async def _as_write_get(data, sock):
    try:
        n = sock.write(data)
    except OSError:
        pass
async def _as_write_post(data, pdata, sock):
    try:
        pp = sock.write(data)
        time.sleep_ms(50)
        pp = sock.write(pdata)
    except OSError:
        pass
async def _as_write_post(data, pdata, sock):
    try:
        pp = sock.write(data)
        time.sleep_ms(50)
        pp = sock.write(pdata)
    except OSError:
        pass
async def _as_read(sock):
    s_response = ''
    response_lines = 0
    while True:
        response_lines += 1
        data = sock.read(256)
        if data is not None:              # Если сервер не закрывает соединение (например, как bash [nc -l -p 80]), то возвращается s_response = 'empty'
            s_response += str(data.decode(), 'utf8')
            if response_lines > 3:        # Задача была получить первые 3 строки ответа включая заголовки
                return s_response
                break
        else:
            s_response = 'empty'
            return s_response
            break
async def ahttp(url, method, _PDATA, t):
    print("Fetching:", url)
    proto, _, host, path = url.split('/', 3)      # trailing slash are important!
    google = '8.8.8.8'
    # Вариант проверки наличия выхода в сеть, блокирующий процесс на время выполения ping, но контролируется таймаутом
    # Проверка подключения к сети station.isconnected(), следом за ним пинг, или целевого хоста, или google
    if station.isconnected():
        _pong = ping.ping(google, 2, 1000)     # host | google
        if _pong > 0:
            pass
        else:
            as_response = 'ping error'
            return as_response
    else:
        as_response = 'not connected'
        return as_response
    # 
    if proto == "http:":
        port = 80
    elif proto == "https:":
        import ussl
        port = 443
    addr = socket.getaddrinfo(host, port)[0][-1]
    s = socket.socket()
    s.setblocking(0)                # s.setblocking(False)
    s.settimeout(t)                 # s.settimeout(0.0)
    try:
        s.connect(addr)
        if proto == "https:":
            s = ussl.wrap_socket(s, server_hostname=host)
        if method == "GET":
            data = bytes('GET /%s HTTP/1.0\r\nHost: %s\r\nUser-Agent: ESP32\r\nConnection: close\r\n\r\n' % (path, host), 'utf8')
            await asyncio.wait_for(_as_write_get(data, sock=s), timeout=t)  # отправка заголовков GET
        if method == "POST":
            pdata = _PDATA
            data = bytes('POST /%s HTTP/1.0\r\nHost: %s\r\nUser-Agent: ESP32\r\nContent-Type: application/json\r\nConnection: close\r\nContent-Length: %s\r\n\r\n' % (path, host, str(len(pdata))), 'utf8')
            await asyncio.wait_for(_as_write_post(data, pdata, sock=s), timeout=t)      # отправка заголовков POST и данных pdata
        await asyncio.sleep_ms(100)                                     # пауза между отправкой в сокет и чтением из него
        as_response = await asyncio.wait_for(_as_read(s), timeout=t)    # чтение заголовков/ответа сервера, прерывается по таймауту t
        s.close()
    except OSError:
        as_response = 'OSError 1'     # if server not respond or slower than defined timeout
    except ValueError:
        as_response = 'ValueError'
    except UnicodeError:
        as_response = 'UnicodeError'
    return as_response
    

import uping2

def ping(host, c, to):
    pong = uping2.ping(host, count=c, timeout=to, interval=100, quiet=True)
    # uping2.ping('8.8.8.8', count=3, timeout=1000, interval=100, quiet=True)
    # return 3
    return pong
    

    # return (n_trans, n_recv)
    return n_recv
    

async def print_lines():
    count = 0
    while True:
        await asyncio.sleep(1)
        count += 1
        print("l", count)

async def send_controller():
    count = 0
    while True:
        await asyncio.sleep(5)
        count += 1
        print("send", count)
        # PDATA = '{"msg":"text","body":"status"}'
        # rr = await asyncio.create_task(ahttp.ahttp('http://192.168.43.194/post', 'POST', PDATA, 3))
        # таймаут 15 секунд
        rr = await asyncio.create_task(ahttp.ahttp('http://192.168.43.194/ts', 'GET', 'null', 15))
        print('>>>>>>>>', rr, '<<<<<<<<<<<<<<')

asyncio.create_task(print_lines())        # чисто для визуализации интервалов
asyncio.create_task(send_controller())