How do I use my droplet as a server using the python websockets module?

Hi there @robertwdg,

It does not look like a firewall problem. I can see that there was a similar problem reported here and what fixed the problem for the user was installing nest_asyncio:

pip install nest_asyncio

And adding the following lines:

import nest_asyncio
nest_asyncio.apply()

Let me know how it goes! Regards, Bobby

Heya,

Another approach would be to error you’re encountering, RuntimeError: This event loop is already running, is not related to network firewalls or your droplet’s configuration but rather to how you’re using asyncio in your program.

Explanation:

This error occurs because you’re trying to run a new event loop (run_until_complete) in an environment where an event loop is already running. This is common in environments like Jupyter Notebooks, or in certain integrated development environments (IDEs) like Spyder or PyCharm.

Here’s how to address it:

Solution:

1. Check the Environment:

   • If you’re running the code in an environment that already manages an event loop (e.g., Jupyter Notebook or certain IDEs), try running your code directly from the command line or terminal. This avoids the problem entirely.

2. Use await instead of run_until_complete():

   • Since you already have an event loop running, you can directly await your coroutine instead of using asyncio.get_event_loop().run_until_complete(). This method works inside an already running event loop.

   Here’s an example of how you can modify your code:

import asyncio
import websockets

async def communicate():
    async with websockets.connect('ws://your_droplet_ip:port') as websocket:
        # Your communication logic here
        pass

# Instead of run_until_complete, use await if you're already in an event loop
if __name__ == "__main__":
    asyncio.run(communicate())  # Use asyncio.run in Python 3.7+

Use asyncio.run() (Python 3.7+):

• The asyncio.run() function was introduced in Python 3.7 to run a coroutine and manage the event loop cleanly. This function simplifies the process and avoids the issue of a running event loop.

Replace asyncio.get_event_loop().run_until_complete(communicate()) with:

asyncio.run(communicate())