Function track_request

api/app_analytics/tasks.py:118–143

(
    resource: int,
    host: str,
    environment_key: str,
    count: int = 1,
    labels: Labels | None = None,
)

@register_task_handler()
def track_request(
    resource: int,
    host: str,
    environment_key: str,
    count: int = 1,
    labels: Labels | None = None,
) -> None:
    if environment := Environment.get_from_cache(environment_key):
        resource = Resource(resource)
        labels = labels or {}
        if settings.USE_POSTGRES_FOR_ANALYTICS:
            APIUsageRaw.objects.create(
                resource=resource,
                host=host,
                environment_id=environment.id,
                count=count,
                labels=labels,
            )
        elif settings.INFLUXDB_TOKEN:
            track_request_influxdb(
                resource=resource,
                host=host,
                environment=environment,
                count=count,
                labels=labels,
            )


track_feature_evaluation_influxdb_v2 = register_task_handler()(