async_neo4j_create_and_query_person_node.py

1import asyncio
2from neo4j import AsyncGraphDatabase
3
4# Connection details
5URI = "neo4j://localhost:7687"
6AUTH = ("neo4j", "password")
7
8async def main():
9    # The driver object manages a pool of connections
10    async with AsyncGraphDatabase.driver(URI, auth=AUTH) as driver:
11        # Create a session to run Cypher queries
12        async with driver.session(database="neo4j") as session:
13            # Run a query to create a node
14            await session.run("CREATE (p:Person {name: $name})", name="Alice")
15
16            # Run a query to retrieve data
17            result = await session.run("MATCH (p:Person) RETURN p.name AS name")
18            async for record in result:
19                print(f"Found person: {record['name']}")
20
21if __name__ == "__main__":
22    asyncio.run(main())