from flask import Flask
    from fawn import Fawn
    app = Flask(__name__)

    # If you are using Flask SQLAlchemy:
    from flask_sqlalchemy import SQLAlchemy
    app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql+psycopg2:https://user@localhost/db'
    db = SQLAlchemy(app)

    # If you are using SQLAlchemy
    # from sqlalchemy import create_engine
    # engine = create_engine('postgresql+psycopg2:https://user@localhost/db', echo=True)

    def connection_factory():
        connection = db.engine.connect()  # or engine.connect() with sqlalchemy
        connection.detach()
        return connection.connection.connection  # oh yeah

    # If your are using directly psycopg2
    # def connection_factory():
    #     return psycopg2.connect('dbname=db user=user')

    fawn = Fawn(connection_factory)

    # You can now declare a websocket route:
    @app.route('/ws/')
    @fawn.websocket
    class ws(fawn.WebSocket):
        def open(self):
            print('Opened')

        def message(self, message):
            print('Message ', message)

        def notify(self, payload):
            self.send('Got payload %s' % payload)

        def close(self, reason):
            print('Closed (%r)' % reason)

    # And declare a very simple route
    @app.route('/')
    def index():
        # All connected websockets to the ws endpoint can be notified with:
        db.session.execute(fawn.notify('ws', 'From the endpoint'))
        db.session.commit()

        # Can be used directly in sql with:
        # => NOTIFY endpoint, 'payload'

        # A little js to show it on the page
        return """
        <script>
            var s = new WebSocket("ws:https://" + location.host + "/ws/");
            s.onopen = e => document.write('opened')
            s.onmessage = e => document.write(e.data)
            s.onerror = e => document.write('Error')
            s.onclose = e => document.write('connection closed')
        </script>
        """