Tracks the usage of an endpoint by an actor.
This function increments the usage count for a given endpoint by an actor.
It also handles initialization if the count does not exist.
Parameters:
| Name |
Type |
Description |
Default |
endpoint |
str
|
The endpoint being accessed.
|
required
|
actor |
str
|
The actor accessing the endpoint.
|
required
|
n |
int
|
The number of times the endpoint was accessed. Defaults to 1.
|
1
|
Returns:
| Name | Type |
Description |
None |
|
This function does not return anything but updates the memcache client.
|
Source code in inference/core/usage.py
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63 | def trackUsage(endpoint, actor, n=1):
"""Tracks the usage of an endpoint by an actor.
This function increments the usage count for a given endpoint by an actor.
It also handles initialization if the count does not exist.
Args:
endpoint (str): The endpoint being accessed.
actor (str): The actor accessing the endpoint.
n (int, optional): The number of times the endpoint was accessed. Defaults to 1.
Returns:
None: This function does not return anything but updates the memcache client.
"""
# count an inference
try:
job = endpoint + "endpoint:::actor" + actor
current_infers = memcache_client.incr(job, n)
if current_infers is None: # not yet set; initialize at 1
memcache_client.set(job, n)
current_infers = n
# store key
job_keys = memcache_client.get("JOB_KEYS")
if job_keys is None:
memcache_client.add("JOB_KEYS", json.dumps([job]))
else:
decoded = json.loads(job_keys)
decoded.append(job)
decoded = list(set(decoded))
memcache_client.set("JOB_KEYS", json.dumps(decoded))
actor_keys = memcache_client.get("ACTOR_KEYS")
if actor_keys is None:
ak = {}
ak[actor] = n
memcache_client.add("ACTOR_KEYS", json.dumps(ak))
else:
decoded = json.loads(actor_keys)
if actor in actor_keys:
actor_keys[actor] += n
else:
actor_keys[actor] = n
memcache_client.set("ACTOR_KEYS", json.dumps(actor_keys))
except Exception as e:
logger.debug("WARNING: there was an error in counting this inference")
logger.debug(e)
|