async_db_playground

My personal playground to test some python async features and their interaction in a "real" scenario.

Use:

If you want to try this examples you need to install:

• Postgresql 9.4 (or later)
• Python 3.5 (or later)
• Python dependencies listed in /pip_requirements.txt

Database:

• Creation: To create the database you should use the commands listed in db/create_db.sql
• Model: To deploy the model you should use the script db/adm_deploy_db.sh or manually deploy it in the order listed in db/create_model.sql

examples / async_notify /

This is a simple Proof of Concept to get real time notifications from the Database and display them on the screen. I'll use the base of this POC for async_notify_dbsync.

examples / async_db_sync /

This POC aims to create a replication mechanism between two given tables using:

• python3.5 (asyncio + ThreadPoolExecutor + psycopg2 + sqlalchemy)
• Postgresql 9.4 (Notifications + json features).py It's not intended to be used as a replication mechanisms in a production environment. Is just a POC. Several implementation decisions are based on this zzzeek blog entry if you are interested I recommend you to read it.

Other references:

• Psycopg2

  • asynchronous-notifications
  • asynchronous-support
  • connection.fileno

• SqlAlchemy

  • zzzeek about async db
  • contextual session
  • session pooling

• Python Asyncion and threads

  • executor
  • thread pooling
  • asyncio and threads example