ENG-2883 Remove fideslog (#7735)

Co-authored-by: eastandwestwind <eastandwestwind@gmail.com>

Author: erosselli

.fides/db_dataset.yml

@@ -2479,35 +2479,6 @@ dataset:
     - name: updated_at
       data_categories:
       - system.operations
-  - name: userregistration
-    description: 'Records the registration status of this Fides deployment'
-    data_categories: null
-    fields:
-    - name: id
-      data_categories:
-      - system.operations
-    - name: created_at
-      data_categories:
-      - system.operations
-    - name: updated_at
-      data_categories:
-      - system.operations
-    - name: analytics_id
-      description: 'The identifier for this Fides deployment within Fideslog'
-      data_categories:
-      - system.operations
-    - name: opt_in
-      description: 'Whether the user has opted to share analytics data'
-      data_categories:
-      - system.operations
-    - name: user_email
-      description: 'The email of the user setting this opt_in preference'
-      data_categories:
-      - user.contact.email
-    - name: user_organization
-      description: 'The name of the organization this Fides deployment belongs to'
-      data_categories:
-      - user.workplace
   - name: cookies
     description: 'Fides Generated Description for Table: cookies'
     data_categories: []

changelog/7735-remove-fideslog-analytics.yaml

@@ -0,0 +1,4 @@
+type: Removed
+description: Removed the fideslog analytics dependency
+pr: 7735
+labels: [db-migration]

docs/fides/docs/development/fideslog.md

@@ -28,7 +28,6 @@ nav:
           - Releases: development/releases.md
           - Using Postman: development/postman/using_postman.md
           - Updating the Database Diagram: development/update_erd_diagram.md
-          - User Analytics: development/fideslog.md
       - Community:
           - Github, Slack, and Discord: community/overview.md
           - Community Hints and Tips: community/hints_tips.md

docs/fides/mkdocs.yml

@@ -28,7 +28,7 @@ dependencies = [
     "PyMySQL==1.1.1",
     "SQLAlchemy-Utils==0.38.3",
     "acryl-datahub==1.3.1.3",
-    "aiodns~=3.5.0",
+    "aiohttp==3.13.3",
     "aiohappyeyeballs~=2.6.1",
     "alembic==1.8.1",
     "anyascii==0.3.2",
@@ -56,7 +56,6 @@ dependencies = [
     "fastapi-pagination[sqlalchemy]==0.15.0",
     "fastapi[all]==0.123.3",
     "fideslang==3.1.4a1",
-    "fideslog==1.2.15",
     "firebase-admin==5.3.0",
     "flower==2.0.1",
     "google-auth==2.48.0",
@@ -249,7 +248,6 @@ module = [
   "dask.*",
   "deepdiff.*",
   "defusedxml.ElementTree.*",
-  "fideslog.*",
   "firebase_admin.*",
   "google.api_core.*",
   "joblib.*",

pyproject.toml

@@ -0,0 +1,52 @@
+"""drop legacy userregistration table
+
+Revision ID: 25ffa8bf6a95
+Revises: a1ca9ddf3c3c
+Create Date: 2026-03-23 12:00:00.000000
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "25ffa8bf6a95"
+down_revision = "a1ca9ddf3c3c"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.execute("DROP INDEX IF EXISTS ix_userregistration_id")
+    op.execute("DROP TABLE IF EXISTS userregistration CASCADE")
+
+
+def downgrade() -> None:
+    op.create_table(
+        "userregistration",
+        sa.Column("id", sa.String(length=255), nullable=False),
+        sa.Column(
+            "created_at",
+            sa.DateTime(timezone=True),
+            server_default=sa.text("now()"),
+            nullable=True,
+        ),
+        sa.Column(
+            "updated_at",
+            sa.DateTime(timezone=True),
+            server_default=sa.text("now()"),
+            nullable=True,
+        ),
+        sa.Column("user_email", sa.String(), nullable=True),
+        sa.Column("user_organization", sa.String(), nullable=True),
+        sa.Column("analytics_id", sa.String(), nullable=False),
+        sa.Column("opt_in", sa.Boolean(), nullable=False),
+        sa.PrimaryKeyConstraint("id"),
+        sa.UniqueConstraint("analytics_id"),
+    )
+    op.create_index(
+        op.f("ix_userregistration_id"),
+        "userregistration",
+        ["id"],
+        unique=False,
+    )

src/fides/api/alembic/migrations/versions/xx_2026_03_23_1200_25ffa8bf6a95_drop_userregistration_table.py

@@ -18,7 +18,6 @@
 
 import fides
 from fides.api.asgi_middleware import (
-    AnalyticsLoggingMiddleware,
     AuditLogMiddleware,
     LogRequestMiddleware,
     ProfileRequestMiddleware,
@@ -129,9 +128,6 @@ def create_fides_app(
     if CONFIG.dev_mode:
         fastapi_app.add_middleware(ProfileRequestMiddleware)
 
-    if not CONFIG.user.analytics_opt_out:
-        fastapi_app.add_middleware(AnalyticsLoggingMiddleware)
-
     fastapi_app.add_middleware(LogRequestMiddleware)
 
     if CONFIG.security.enable_audit_log_resource_middleware:

src/fides/api/analytics.py

@@ -7,29 +7,19 @@
 
 from __future__ import annotations
 
-import asyncio
 import re
 from abc import ABC, abstractmethod
-from datetime import datetime, timezone
 from time import perf_counter
 from typing import Any, Awaitable, Callable, MutableMapping, Optional, Set
 from uuid import uuid4
 
-from fideslog.sdk.python.event import AnalyticsEvent
 from loguru import logger
 from pyinstrument import Profiler
 from starlette.requests import Request
 
-from fides.api.analytics import (
-    accessed_through_local_host,
-    in_docker_container,
-    send_analytics_event,
-)
 from fides.api.middleware import handle_audit_log_resource
 from fides.api.request_context import set_request_id
-from fides.api.schemas.analytics import Event, ExtraData
 from fides.api.util.endpoint_utils import API_PREFIX
-from fides.api.util.logger import _log_exception
 from fides.config import CONFIG
 
 # Type aliases for ASGI
@@ -228,107 +218,6 @@ async def handle_http(self, scope: Scope, receive: Receive, send: Send) -> None:
         ).info("Request received")
 
 
-class AnalyticsLoggingMiddleware(BaseASGIMiddleware):
-    """
-    Pure ASGI middleware that logs analytics events for each call to Fides endpoints.
-
-    Only logs for API endpoints (paths starting with API_PREFIX) and skips /health endpoints.
-    """
-
-    # Class-level set to hold references to pending tasks, preventing garbage collection
-    # before completion. Tasks remove themselves from this set when done.
-    _pending_tasks: set[asyncio.Task] = set()
-
-    def __init__(self, app: ASGIApp, api_prefix: str = API_PREFIX) -> None:
-        super().__init__(app)
-        self.api_prefix = api_prefix
-
-    async def handle_http(self, scope: Scope, receive: Receive, send: Send) -> None:
-        path = self.get_path(scope)
-
-        # Skip non-API endpoints and health endpoints
-        if not path.startswith(self.api_prefix) or path.endswith("/health"):
-            await self.app(scope, receive, send)
-            return
-
-        method = self.get_method(scope)
-        fides_source: Optional[str] = self.get_header(scope, b"x-fides-source") or None
-        hostname = self.get_host(scope)
-        full_url = self.build_url(scope)
-
-        now = datetime.now(tz=timezone.utc)
-        endpoint = f"{method}: {full_url}"
-
-        # Capture status and detect HTTP errors
-        captured: dict[str, Any] = {"status": 500, "error_class": None}
-
-        async def send_wrapper(message: Message) -> None:
-            if message["type"] == "http.response.start":
-                status_code: int = message.get("status", 500)
-                captured["status"] = status_code
-                if status_code >= 400:
-                    captured["error_class"] = "HTTPException"
-            await send(message)
-
-        try:
-            await self.app(scope, receive, send_wrapper)
-        except Exception as e:
-            captured["status"] = 500
-            captured["error_class"] = e.__class__.__name__
-            _log_exception(e, CONFIG.dev_mode)
-            raise
-        finally:
-            # Schedule analytics logging as a background task.
-            # Store task reference to prevent garbage collection before completion.
-            task = asyncio.create_task(
-                self._log_analytics(
-                    endpoint,
-                    hostname,
-                    captured["status"],
-                    now,
-                    fides_source,
-                    captured["error_class"],
-                )
-            )
-            self._pending_tasks.add(task)
-            # Task will be passed as argument to discard when it completes
-            task.add_done_callback(self._pending_tasks.discard)
-
-    async def _log_analytics(
-        self,
-        endpoint: str,
-        hostname: Optional[str],
-        status_code: int,
-        event_created_at: datetime,
-        fides_source: Optional[str],
-        error_class: Optional[str],
-    ) -> None:
-        """Log analytics event if not opted out."""
-        if CONFIG.user.analytics_opt_out:
-            return
-
-        try:
-            await send_analytics_event(
-                AnalyticsEvent(
-                    docker=in_docker_container(),
-                    event=Event.endpoint_call.value,
-                    event_created_at=event_created_at,
-                    local_host=accessed_through_local_host(hostname),
-                    endpoint=endpoint,
-                    status_code=status_code,
-                    error=error_class or None,
-                    extra_data=(
-                        {ExtraData.fides_source.value: fides_source}
-                        if fides_source
-                        else None
-                    ),
-                )
-            )
-        except Exception:
-            # Analytics should never break the request
-            pass
-
-
 class AuditLogMiddleware(BaseASGIMiddleware):
     """
     Pure ASGI middleware that logs audit information for non-GET requests.

src/fides/api/app_setup.py

@@ -91,7 +91,6 @@
     Property,
 )
 from fides.api.models.questionnaire import ChatMessage, Questionnaire
-from fides.api.models.registration import UserRegistration
 from fides.api.models.saas_template_dataset import SaasTemplateDataset
 from fides.api.models.storage import StorageConfig
 from fides.api.models.system_compass_sync import SystemCompassSync