Function track_request_influxdb

api/app_analytics/track.py:86–113

Sends API event data to InfluxDB :param request: (HttpRequest) the request being made

(
    resource: Resource,
    host: str,
    environment: "Environment",
    count: int,
    labels: Labels,
)

def track_request_influxdb(
    resource: Resource,
    host: str,
    environment: "Environment",
    count: int,
    labels: Labels,
) -> None:
    """
    Sends API event data to InfluxDB

    :param request: (HttpRequest) the request being made
    """
    if resource.is_tracked:
        tags: dict[str, str | int | float] = {
            "resource": resource.resource_name,
            "organisation": environment.project.organisation.get_unique_slug(),
            "organisation_id": environment.project.organisation_id,
            "project": environment.project.name,
            "project_id": environment.project_id,
            "environment": environment.name,
            "environment_id": environment.id,
            "host": host,
            **map_labels_to_influx_record_values(labels),
        }

        influxdb = InfluxDBWrapper("api_call")  # type: ignore[no-untyped-call]
        influxdb.add_data_point("request_count", count, tags=tags)
        influxdb.write()


def track_feature_evaluation_influxdb(