Newer
Older
Nikolay Stanchev
committed
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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
#!/bin/bash
sfc="fms-sfc"
sfci="fms-sfc-1"
service_function="fms-storage"
endpoint="fms-storage-endpoint"
measurement="graph_measurement"
response_time_field="mean(processing_time_rate)/1000"
request_size_field="mean(bytes_received_rate)"
response_size_field="mean(bytes_sent_rate)"
ue="ue22"
rtt_measurement="graph_query"
query_period=30
while true
do
echo "Building temporal graph..."
end=$(date +%s)
start=$((${end}-${query_period}))
echo "Start - ${start}, End - ${end}"
JSON_STRING=$( jq -n \
--arg sfc "${sfc}" \
--arg sfci "${sfci}" \
--arg sf "${service_function}" \
--arg measurement "${measurement}"\
--arg response_time "${response_time_field}"\
--arg request_size "${request_size_field}"\
--arg response_size "${response_size_field}"\
--argjson from ${start}\
--argjson to ${end}\
'{from: $from, to: $to, service_function_chain: $sfc, service_function_chain_instance: $sfci, service_functions: {($sf): {measurement_name: $measurement, response_time_field: $response_time, request_size_field: $request_size, response_size_field: $response_size}}}' )
echo ${JSON_STRING}
echo "Sending build request to CLMC"
response=$(curl -s -X POST -d "${JSON_STRING}" http://172.40.231.51/clmc-service/graph/temporal)
echo ${response}
timestamp=$(echo ${response} | jq -r '.graph.time_range.to')
graph_uuid=$(echo ${response} | jq -r '.graph.uuid')
echo ${graph_uuid}
echo ${timestamp}
echo "Querying for round-trip time..."
response=$(curl -s -X GET "http://172.40.231.51/clmc-service/graph/temporal/${graph_uuid}/round-trip-time?startpoint=${ue}&endpoint=${endpoint}")
echo ${response}
tags=$(echo ${response} | jq -r '.global_tags | to_entries | map("\(.key)=\(.value|tostring)") | join(",")')
echo ${tags}
rtt=$(echo ${response} | jq -r '.round_trip_time')
echo ${rtt}
measurement_line="${rtt_measurement},${tags} round_trip_time=${rtt} ${timestamp}"
response=$(curl -si -XPOST "http://172.40.231.51/influxdb/write?db=${sfc}" --data-binary "${measurement_line}")
echo ${response}
echo "Deleting temporal graph..."
echo $(curl -s -X DELETE "http://172.40.231.51/clmc-service/graph/temporal/${graph_uuid}")
sleep ${query_period}
done