|
@@ -37,6 +37,7 @@ def make_counter_payload(use_case, org_id, rand_str):
|
|
|
|
|
|
def make_dist_payload(use_case, org_id, rand_str, value_len, b64_encode):
|
|
|
nums = [random.random() for _ in range(value_len)]
|
|
|
+ print(f"nums: {nums}")
|
|
|
return {
|
|
|
"name": f"d:{use_case}/duration@second",
|
|
|
"tags": {
|
|
@@ -55,8 +56,8 @@ def make_dist_payload(use_case, org_id, rand_str, value_len, b64_encode):
|
|
|
}
|
|
|
if b64_encode
|
|
|
else {
|
|
|
- "format": "array",
|
|
|
- "data": nums,
|
|
|
+ "format": "zstd",
|
|
|
+ "data": "KLUv/QBYrQAAcAAA8D8AQAAAAAAAAAhAAgBgRgCw",
|
|
|
}
|
|
|
),
|
|
|
"org_id": org_id,
|
|
@@ -104,7 +105,7 @@ def make_gauge_payload(use_case, org_id, rand_str):
|
|
|
"tags": {
|
|
|
"environment": "production",
|
|
|
"session.status": "errored",
|
|
|
- f"metric_e2e_{use_case}_set_k_{rand_str}": f"metric_e2e_{use_case}_set_v_{rand_str}",
|
|
|
+ f"metric_e2e_{use_case}_gauge_k_{rand_str}": f"metric_e2e_{use_case}_gauge_v_{rand_str}",
|
|
|
},
|
|
|
"timestamp": int(datetime.datetime.now(tz=datetime.UTC).timestamp()),
|
|
|
"type": "g",
|