Rename telemetry to usage (feast-dev#1800)

felixwang9817 · web-flow · commit 5e61a6f17c3b · 2021-08-25T09:17:49.000-07:00
Signed-off-by: Felix Wang &lt;wangfelix98@gmail.com&gt;
diff --git a/sdk/python/feast/usage.py b/sdk/python/feast/usage.py
@@ -25,7 +25,7 @@
 
 from feast.version import get_version
 
-USAGE_ENDPOINT = "https://us-central1-kf-feast.cloudfunctions.net/bq_telemetry_logger"
+USAGE_ENDPOINT = "https://usage.feast.dev"
 _logger = logging.getLogger(__name__)
 
 
@@ -83,7 +83,7 @@ def log(self, function_name: str):
                 self._usage_counter["get_online_features"] = 2  # avoid overflow
             json = {
                 "function_name": function_name,
-                "telemetry_id": self.usage_id,
+                "usage_id": self.usage_id,
                 "timestamp": datetime.utcnow().isoformat(),
                 "version": get_version(),
                 "os": sys.platform,
@@ -104,7 +104,7 @@ def log_exception(self, error_type: str, traceback: List[Tuple[str, int, str]]):
             json = {
                 "error_type": error_type,
                 "traceback": traceback,
-                "telemetry_id": self.usage_id,
+                "usage_id": self.usage_id,
                 "version": get_version(),
                 "os": sys.platform,
                 "is_test": self._is_test,
diff --git a/sdk/python/usage_tests/test_usage.py b/sdk/python/usage_tests/test_usage.py
@@ -142,16 +142,16 @@ def read_bigquery_usage_id(usage_id):
     bq_client = bigquery.Client()
     query = f"""
                 SELECT
-                  telemetry_id
+                  usage_id
                 FROM (
                   SELECT
-                    JSON_EXTRACT(textPayload, '$.telemetry_id') AS telemetry_id
+                    JSON_EXTRACT(textPayload, '$.usage_id') AS usage_id
                   FROM
                     `{USAGE_BIGQUERY_TABLE}`
                   WHERE
                     timestamp >= TIMESTAMP(\"{datetime.utcnow().date().isoformat()}\"))
                 WHERE
-                  telemetry_id = '\"{usage_id}\"'
+                  usage_id = '\"{usage_id}\"'
             """
     query_job = bq_client.query(query)
     return query_job.result()
