fluffy-engine

Fluffy Engineは、クリック、ページビュー、トランザクションなどの大量のユーザー生成イベントを取り込み、処理するために設計されたNestJSベースの分析サービスプロトタイプです。 このサービスは、RESTエンドポイントを通じて受信したイベントを受け取り、`analytics-events`という名前のKafkaトピックにキューイングします。Kafkaブローカーはデフォルトで`localhost:9092`となっており、`KAFKA_BROKER`環境変数で設定可能です。その後、イベントは消費され、保存され、APIエンドポイントを通じて利用可能になります。 永続化については、`DATABASE_URL`環境変数を通じてPostgreSQLをサポートしており、接続文字列が提供されない場合はインメモリのSQLiteデータベースにフォールバックします。スキーマには、各イベントのタイムスタンプ、タイプ、および生のペイロードが記録されます。 `/metrics`エンドポイントは、直近5分間の1分ごとのイベント数として最近のアクティビティを返し、基本的なリアルタイム分析を提供します。また、公開された分析データのための将来的なインターフェースとして、ダッシュボードが計画されています。