native [recommended] (TCP) via clickhouse-driver <https://github.com/mymarilyn/clickhouse-driver>
async native (TCP) via asynch <https://github.com/long2ice/asynch>
http via requests

Define table

.. code-block:: python

    from sqlalchemy import create_engine, Column, MetaData

    from clickhouse_sqlalchemy import (
        Table, make_session, get_declarative_base, types, engines
    )

    uri = 'clickhouse+native://localhost/default'

    engine = create_engine(uri)
    session = make_session(engine)
    metadata = MetaData(bind=engine)

    Base = get_declarative_base(metadata=metadata)

    class Rate(Base):
        day = Column(types.Date, primary_key=True)
        value = Column(types.Int32)

        __table_args__ = (
            engines.Memory(),
        )

    Rate.__table__.create()

Insert some data

.. code-block:: python

    from datetime import date, timedelta

    from sqlalchemy import func

    today = date.today()
    rates = [
        {'day': today - timedelta(i), 'value': 200 - i}
        for i in range(100)
    ]

And query inserted data

.. code-block:: python

    session.execute(Rate.__table__.insert(), rates)

    session.query(func.count(Rate.day)) \
        .filter(Rate.day > today - timedelta(20)) \
        .scalar()

License

ClickHouse SQLAlchemy is distributed under the MIT license <http://www.opensource.org/licenses/mit-license.php>_.

Keywords

ClickHouse db database cloud analytics

FAQs

What is clickhouse-sqlalchemy?

Is clickhouse-sqlalchemy well maintained?

Did you know?

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install