Function track_feature_evaluation_influxdb

api/app_analytics/track.py:116–140

Sends Feature analytics event data to InfluxDB :param environment_id: (int) the id of the environment the feature is being evaluated within :param feature_evaluations: (dict) A collection of key id / evaluation counts

(
    environment_id: int,
    feature_evaluations: list[TrackFeatureEvaluationsByEnvironmentData],
)

def track_feature_evaluation_influxdb(
    environment_id: int,
    feature_evaluations: list[TrackFeatureEvaluationsByEnvironmentData],
) -> None:
    """
    Sends Feature analytics event data to InfluxDB

    :param environment_id: (int) the id of the environment the feature is being evaluated within
    :param feature_evaluations: (dict) A collection of key id / evaluation counts
    """
    influxdb = InfluxDBWrapper("feature_evaluation")  # type: ignore[no-untyped-call]

    for feature_evaluation in feature_evaluations:
        tags: dict[str | Label, str | int] = {
            "feature_id": feature_evaluation["feature_name"],
            "environment_id": environment_id,
            **map_labels_to_influx_record_values(feature_evaluation["labels"]),
        }
        influxdb.add_data_point(
            "request_count",
            feature_evaluation["evaluation_count"],
            tags=tags,
        )

    influxdb.write()


def track_feature_evaluation_influxdb_v2(