-
Скачайте или клонируйте репозиторий
-
Установите Python версии 3.10 или выше
-
Установите необходимые модули:
pip install -r requirements.txt
-
Установите PostgreSQL и создайте базу данных
-
Установите Kafka и запустите сервер
-
Создайте базу данных ClickHouse на clickhouse.cloud
-
Скопируйте файл
.env.exampleв.envи заполните его, используя таблицу параметров ниже -
Запустите генератор данных:
python producer/main.py
-
Запустите рабочий процесс Faust, сохраняющий данные из Kafka в базу данных:
python consumer/main.py
-
Запустите веб-сервер FastAPI:
uvicorn web.main:app --reload
| Параметр | Описание |
|---|---|
| DB_URL | Строка параметров подключения к PostgreSQL |
| DB_POOL_SIZE | Размер пула соединений с БД |
| SECRET_KEY | Секретный ключ FastAPI |
| KAFKA_URL | Строка параметров подключения к Kafka |
| CLICKHOUSE_HOST | Хост БД ClickHouse |
| CLICKHOUSE_PORT | Порт БД ClickHouse |
| CLICKHOUSE_USERNAME | Имя пользователя БД ClickHouse |
| CLICKHOUSE_PASSWORD | Пароль пользователя БД ClickHouse |
| CLICKHOUSE_SECURE | Подключаться к БД ClickHouse по https? |