---
title: "Connect an application"
url: "https://docs.yugabyte.com/stable/develop/drivers-orms/python/aiopg/"
---

# Connect an application

Connect a Python application using aiopg Driver for YSQL

- [YSQL](/stable/develop/drivers-orms/python/yugabyte-psycopg2/)
- [YCQL](/stable/develop/drivers-orms/python/ycql/)

<!--THE END-->

- [![](/icons/yugabyte.svg) YB Psycopg 2](/stable/develop/drivers-orms/python/yugabyte-psycopg2)
- [![](/icons/yugabyte.svg) YB Psycopg 3](/stable/develop/drivers-orms/python/yugabyte-psycopg3)
- [PG Psycopg 2](/stable/develop/drivers-orms/python/postgres-psycopg2)
- [PG Psycopg 3](/stable/develop/drivers-orms/python/postgres-psycopg3)
- [aiopg](/stable/develop/drivers-orms/python/aiopg)

The following tutorial creates a basic Python application that connects to a YugabyteDB cluster using the [`aiopg`](https://aiopg.readthedocs.io/en/stable/ "aiopg") database adapter, performs a few basic database operations — creating a table, inserting data, and running a SQL query — and prints the results to the screen.

## Prerequisites

Before you start using Aiopg, ensure you have the following:

- YugabyteDB up and running. If you are new to YugabyteDB, follow the steps in [Quick start](/stable/quick-start/linux/ "Quick start") to have YugabyteDB up and running in minutes.
- [Python 3](https://www.python.org/downloads/ "Python 3"), or later, is installed.
- [aiopg](https://aiopg.readthedocs.io/en/stable/ "aiopg") package is installed. Install the package using the following command:
  
  ```sh
  pip3 install aiopg
  ```
  
  For details about using this database adapter, see [aiopg documentation](https://aiopg.readthedocs.io/en/stable/ "aiopg documentation").

## Create the sample Python application

Create a file `yb-sql-helloworld.py` and copy the following code:

```python
import asyncio
import aiopg

dsn = 'dbname=yugabyte user=yugabyte password=yugabyte host=127.0.0.1 port=5433'


async def go():
    async with aiopg.create_pool(dsn) as pool:
        async with pool.acquire() as conn:
            # Open a cursor to perform database operations.
            async with conn.cursor() as cur:
                await cur.execute(f"""
                  DROP TABLE IF EXISTS employee;
                  CREATE TABLE employee (id int PRIMARY KEY,
                             name varchar,
                             age int,
                             language varchar);
                """)
                print("Created table employee")
                # Insert a row.
                await cur.execute("INSERT INTO employee (id, name, age, language) VALUES (%s, %s, %s, %s)",
                                  (1, 'John', 35, 'Python'))
                print("Inserted (id, name, age, language) = (1, 'John', 35, 'Python')")

                # Query the row.
                await cur.execute("SELECT name, age, language FROM employee WHERE id = 1")
                async for row in cur:
                    print("Query returned: %s, %s, %s" % (row[0], row[1], row[2]))


loop = asyncio.get_event_loop()
loop.run_until_complete(go())
```

### Run the application

To use the application, run the following Python script:

```sh
python yb-sql-helloworld.py
```

You should see the following output:

```output
Created table employee
Inserted (id, name, age, language) = (1, 'John', 35, 'Python')
Query returned: John, 35, Python
```