Coverage for docs_src / async_tutorial / async_example.py: 100%

1import asyncio 6 ctx1abcdef

2import os 6 ctx1abcdef

3 

4from mongodb_odm import Document, Field, adisconnect, async_apply_indexes, connect 6 ctx1abcdef

5 

6MONGO_URL = os.environ.get("MONGO_URL", "mongodb://localhost:27017/testdb") 6 ctx1abcdef

7 

8 

9class User(Document): 6 ctx1abcdef

10 name: str = Field() 6 ctx1abcdef

11 email: str = Field() 6 ctx1abcdef

12 

13 

14async def main(): 6 ctx1abcdef

15 connect(MONGO_URL, async_is_enabled=True) 6 ctx1abcdef

16 await async_apply_indexes() 6 ctx1abcdef

17 

18 # Create document 

19 user = User(name="John", email="john@example.com") 6 ctx1abcdef

20 await user.acreate() 6 ctx1abcdef

21 

22 # Find documents 

23 _users = [user async for user in User.afind({"name": "John"})] 6 ctx1abcdef

24 

25 # Update document 

26 await user.aupdate({"$set": {"name": "Jane"}}) 6 ctx1abcdef

27 

28 # Delete document 

29 await user.adelete() 6 ctx1abcdef

30 

31 # Cleanup 

32 await adisconnect() 6 ctx1abcdef

33 

34 

35asyncio.run(main()) 6 ctx1abcdef