Как подключать библиотеки?

from asyncio import open_connection, get_event_loop, Queue, start_server
from json import dumps, loads
from collections import defaultdict

from settings import *
 
async def mapper(loop):
    reader, writer = await open_connection(ADDR, PORT, loop=loop)
    data = await reader.readuntil()
    result = defaultdict(int)
    with open(data.decode().rstrip(),'r') as f:
        for line in f:
            for word in line.rstrip().split():
                result[word.lower()] += 1
    writer.write(f'{dumps(result[WORD])}\n'.encode())
    await writer.drain()
    writer.close()
 
loop = get_event_loop()
loop.run_until_complete(mapper(loop)) and loop.close()

from settings import *
 
processed, result, files = Queue(len(FILES)), 0, Queue()
loop = get_event_loop()
[files.put_nowait(f) for f in FILES]
 
async def conn(reader, writer):
    filename = await files.get()
    writer.write(filename.encode())
    await writer.drain()
    res = await reader.readuntil()
    writer.close()
    global result
    result += int(res.decode().rstrip())
    await processed.put(filename)
    if processed.full():
        print(f'word <<{WORD}>> appeared {result} times')
        loop.stop()
 
coro = start_server(conn, ADDR, PORT, loop=loop)
server = loop.run_until_complete(coro)
try:
    loop.run_forever()
finally:
    server.close()

from asyncio import open_connection, get_event_loop, Queue, start_server
from json import dumps, loads
from collections import defaultdict
from os import listdir, path
 
ADDR, PORT, DATADIR, WORD  = '127.0.0.1', 8764, 'data', 'он'
FILES = [f'{path.join(DATADIR, f)}\n' for f in listdir(DATADIR)]

from collections import defaultdict
from os import listdir, path
 
result = defaultdict(int)
DATADIR = 'data'
WORD = 'он'
FILES = [f'{path.join(DATADIR, f)}' for f in listdir(DATADIR)]
 
for file_ in FILES:
    with open(file_, 'r') as f:
        for line in f:
            for word in line.rstrip().split():
                result[word.lower()] += 1
 
print(f'word <<{WORD}>> appeared {result[WORD]} times')

from asyncio import open_connection, get_event_loop, Queue, start_server
from json import dumps, loads
from collections import defaultdict