A Flask extension for CuttlePool
Flask-CuttlePool provides a convenient interface for using Cuttle Pool with Flask.
If you haven’t read the How-to Guide for CuttlePool, you really should before going any further.
FlaskCuttlePool objects accept the same arguments as CuttlePool objects, as well as a Flask app object. Assume we have the following imports and app object.
import sqlite3 from flask import Flask from flask_cuttlepool import FlaskCuttlePool app = Flask(__name__)
There are two ways to set up a pool object. On pool initialization
pool = FlaskCuttlePool(sqlite3.connect, app=app, database='ricks_lab')
or using init_app() explicitly
pool = FlaskCuttlePool(sqlite3.connect) pool.init_app(app)
Any configuration keys that start with CUTTLEPOOL_ will be converted to a key value pair. If the key already exists in the initial arguments passed to the __init__() method, those will be superceded by the value on app.config. For example
pool = FlaskCuttlePool(sqlite3.connect, database='ricks_lab') app.config['CUTTLEPOOL_DATABASE'] = 'citadel_of_ricks' pool.init_app(app)
will result in the connection pool associated with that app object connecting to 'citadel_of_ricks' instead of 'ricks_lab'. Every key value pair on app.config of the form app.config['CUTTLEPOOL_KEY'] = value is passed to the pool constructor as key=value where key is lowercase.
FlaskCuttlePool objects should also be provided with two callbacks. The ping callback is used to check if a connection is still open. The normalize_connection callback ensures each connection has the same state when it is retrieved from the pool. For more about these methods, see the Cuttle Pool How-to Guide.
Continuing with the above example, these callbacks could be implemented like this:
@pool.ping def ping(connection): try: rv = connection.execute('SELECT 1').fetchall() return (1,) in rv except sqlite3.Error: return False @pool.normalize_connection def normalize_connection(connection): connection.row_factory = None
Now the pool can be used as normal. Any calls to get_connection() will return a connection in the same manner a CuttlePool object would.
To make things more convenient, the connection getter will store a connection on the application context and reuse that connection whenever the connection getter is called again. When the application context is torn down, the connection will be returned to the pool. Therefore, there is no need to call close() on a connection retrieved from the connection getter, but it’s ok if close() is called. Connections retrieved with get_connection() should be explicitly closed.
The convenience method cursor() will return a Cursor instance for the connection stored on the application context.
A full example looks like:
import sqlite3 from flask import Flask from flask_cuttlepool import FlaskCuttlePool app = Flask(__name__) app.config['CUTTLEPOOL_DATABASE'] = ':memory:' pool = FlaskCuttlePool(sqlite3.connect) pool.init_app(app) @pool.ping def ping(connection): try: rv = connection.execute('SELECT 1').fetchall() return (1,) in rv except sqlite3.Error: return False @pool.normalize_connection def normalize_connection(connection): connection.row_factory = None with app.app_context(): # Get a connection, store it on the application context and return to # user. This connection doesn't need to be explicitly closed. con = pool.connection # Subsequent calls to pool.connection will get the same connection from # the application context. con is pool.connection # True # Get a different connection con2 = pool.get_connection() con2 is con # False # This connection should be explicitly closed since it was retrieved by # get_connection(). con2.close() # Get a cursor from the connection on the application context. cur = pool.cursor() cur.execute(SOME_SQL) cur.close() pool.connection.commit() # Now the application context has been torn down, so the connection has been # returned to the pool. pool.connection is None # True
These questions are related to Flask-CuttlePool only, check the FAQ for CuttlePool if you don’t find your answers here.
How do I install it?
pip install flask-cuttlepool
What is an application contexts?
This is a Flask extension, so it is meant to be used in the context of a Flask application. See here to learn about Flask’s application context.
It’s highly recommended to develop in a virtualenv.
Fork the repository.
Clone the repository:
git clone https://github.com/<your_username>/flask-cuttlepool.git
Install the package in editable mode:
cd flask-cuttlepool pip install -e .[dev]
Now you’re set. See the next section for running tests.
Running the tests
Tests can be run with the command pytest.
Where can I get help?
If you haven’t read the How-to guide above, please do that first. Otherwise, check the issue tracker. Your issue may be addressed there and if it isn’t please file an issue :)
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
|Filename, size||File type||Python version||Upload date||Hashes|
|Filename, size Flask_CuttlePool-0.2.1-py3-none-any.whl (7.1 kB)||File type Wheel||Python version py3||Upload date||Hashes View|
|Filename, size Flask-CuttlePool-0.2.1.tar.gz (6.2 kB)||File type Source||Python version None||Upload date||Hashes View|
Hashes for Flask_CuttlePool-0.2.1-py3-none-any.whl