Wowza Stats – Single Server

Here’s the code for gathering Wowza Stats from a single server. This assumes that you’ve enabled the stats on Wowza (serverinfo, connectioncounts in VHost.xml HTTPProviders), with authentication turned off). You’ll also get better detailed stats if you use Andrew Kennedy’s CasterStats module for the serverinfo.

+ expand source?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15 <HTTPProvider>
        <BaseClass>com.wowza.wms.plugin.test.HTTPServerInfo</BaseClass>
        <RequestFilters>serverinfo*</RequestFilters>
        <AuthenticationMethod>none</AuthenticationMethod>
</HTTPProvider>
<HTTPProvider>
        <BaseClass>com.wowza.wms.http.HTTPConnectionInfo</BaseClass>
        <RequestFilters>connectioninfo*</RequestFilters>
        <AuthenticationMethod>none</AuthenticationMethod>
</HTTPProvider>
<HTTPProvider>
        <BaseClass>com.wowza.wms.http.HTTPConnectionCountsXML</BaseClass>
        <RequestFilters>connectioncounts*</RequestFilters>
        <AuthenticationMethod>none</AuthenticationMethod>
</HTTPProvider>
PHP code:
+ expand source?
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265 <?PHP
error_reporting(0);
header("Content-type: text/html; charset=utf-8");
 
$detailed = false;
$graph_load = false;
$simple_load = false;
$simple_count = false;
$stream_count = false;
$geo_count = false;
$count = false;
$load = false;
$form = true;
 
if (isset($_GET['server'])) { $repeater = $_GET['server']; $form = false;} 
 
if (isset($_GET['mode'])) { 
    switch ($_GET['mode']) {
        case "detailed":  $detailed = true; $count=true; break;
        case "graph_load" : $graph_load = true; $load = true; break;
        case "simple_load" : $simple_load = true; $load = true; break;
        case "simple_count" : $simple_count = true; $load = true; break;
        case "geo_count" : $geo_count = true; $count = true; break;
        case "stream_count" : $stream_count = true; $count = true; break;
    }  
    $form = false;
} else { $form = true; }
if (isset($_GET['port'])) { $adminport = $_GET['port'];} else { $adminport='8086'; }
 
if ($form) {
 
?>
<HTML>
 <HEAD>
  <TITLE>Single-Server Metrics</TITLE>
 </HEAD>
 <BODY>
  <H3>Single-Server Stats Gathering</H3>
  <FORM ACTION="#" METHOD="GET">
   <P>Server Address:<BR>
   <INPUT TYPE="text" size="15" value="<?=$repeater;?>" name="server"></P>
   <P>Admin Port<BR>
   <INPUT TYPE="text" size="15" value="8086" name="port"></P>
   <P>Data to display: <BR>
   <INPUT TYPE="radio" name="mode" value="detailed">Detailed Count</INPUT><BR>
   <INPUT TYPE="radio" name="mode" value="graph_load">Load Graph</INPUT><BR>
   <INPUT TYPE="radio" name="mode" value="simple_load">Load in Mbps</INPUT><BR>
   <INPUT TYPE="radio" name="mode" value="simple_count">Simple Count</INPUT><BR>
   <INPUT TYPE="radio" name="mode" value="geo_count">Geographical Count</INPUT><BR>
   <INPUT TYPE="radio" name="mode" value="stream_count">Stream Count</INPUT><BR>
   <BR>
   <INPUT TYPE="submit" Value="Show Me The Data">
  </FORM>
 </BODY>
</HTML>
 
<?php 
 
} else {
 
 
// Iterate through IP address array
// initialize counters
$agent['iPhone']=0;
$agent['iPad']=0;
$agent['iPod']=0;
$agent['stagefright']=0;
$agent['Roku']=0;
$agent['Flash']=0;
 
$proto['RTMP']=0;
$proto['RTSP']=0;
$proto['HLS']=0;
$proto['2']=0;
$proto['3']=0;
$proto['4']=0;
$server_bwin = 0;
$server_bwout = 0;
$server_conns = 0;
 
 
if ($graph_load) { echo "<H3>Server Load</H3>"; }
 
    $filter = array(
            "Name" => 'ip-address',
            "Value" => $repeater
            );
    $opts = array (
            "Filter" => $filter
            );
     
    if($load) { // compute load per server
 
                $repeaterurl = "http://$repeater:$adminport/connectioncounts";
                $repeaterxml = simplexml_load_file($repeaterurl);
 
                foreach ($repeaterxml->VHost as $vhost) {
                        foreach ($vhost->Application as $app) { // parse bandwidth usage by app in case we want it. 
                $appname = (string)$app->Name;
                if ($app->Status == "Loaded") {
                    $inbytes = (string)$app->MessagesInBytesRate;
                    $outbytes = (string)$app->MessagesOutBytesRate;
                    $bwin[$appname] = $inbytes / 131072; // Convert Bps to Mbps
                    $bwout[$appname] = $outbytes / 131027; // Convert Bps to Mbps
                } 
            } // End App Loop
        } // End VHost Loop
        $server_bwin = (string)$repeaterxml->MessagesInBytesRate / 131072; // Convert Bps to Mbps
        $server_bwout = (string)$repeaterxml->MessagesOutBytesRate / 131072; // Convert Bps to Mbps
        $server_conns = $repeaterxml->ConnectionsCurrent;
 
        if ($graph_load) {
            $server_load = $server_bwout / 1024 * 100; // convert to percentage
 
            $load_string = sprintf("%.2f",$server_load);
            $bwout_string = sprintf("%.3f",$server_bwout);
            $load_round = round($server_load);
     
            switch ($server_load) {
                case ($server_load > 99): $color = "black"; $heavy = true; break;
                case ($server_load >= 85): $color = "red"; $heavy = true; break;
                case ($server_load >= 75): $color = "yellow"; break;
                default: $color = "green";
                }
                $info = '<A HREF="http://'.$repeater.':$adminport/serverinfo.xml" target="_blank">'.$repeater.'</A>: <B>'. $load_string ."%</B> with ". $server_conns . " connections (". $bwout_string ." Mbps out)"; 
                print "<P>" . $info . "</P>"; 
     
            ?>
            <DIV style="height: 5px; background: none repeat scroll 0% 0% #ffffff; border: 2px solid;">
                <DIV style="height: 100%; background: <?=$color?>; color: black; width: <?=$load_round?>%;"></div>
            </div>
            <?php
 
        } // End Load Graph
         
    } // End Bandwidth Loop
 
 
    if($count) {
        $repeaterurl = "http://$repeater:$adminport/serverinfo";
        $repeaterxml = simplexml_load_file($repeaterurl);
         
        foreach ($repeaterxml->VHost as $vhost) {
            foreach ($vhost->Application as $app) {
                foreach ($app->ApplicationInstance as $instance) {
                    foreach ($instance->Client as $client) {
                        // Skip repeaters and encoders - FMS is already filtered out by the HTTPProvider
                        $skip = false; // Init variable
                        if (preg_match('(Repeater)',$client->Referrer)) { $skip = true; }
                        if (preg_match('(Kulabyte)',$client->Referrer)) { $skip = true; }
     
                        if (!$skip) { 
                            $protocol = (string)$client->Protocol;
                            $proto[$protocol]++;
                            $streamnames = (string)$client->StreamNames;
                            $streamarray=explode("/",$streamnames);
                            $str_array_len=sizeof($streamarray);
     
                            $str_end_index = $str_array_len -1;
                            $strname = $streamarray[$str_end_index];
 
                            if ($streamarray[0] == "amazons3") {
                                $vod[$strname]++;
                                } else {
                                $live[$strname]++;
                                }
                            $client_list[] = (string)$client->IpAddress;
 
                            if ($detailed) {
     
                                if ($client->UserAgent) // HTML clients will have a useragent defined
                                    { 
                                        echo $client->IpAddress.": ".$client->UserAgent ."<BR>\n"; 
                                        if (preg_match('(Roku)',$client->UserAgent)) { $agent['Roku']++; }
                                        if (preg_match('(iPhone)',$client->UserAgent)) { $agent['iPhone']++; }
                                        if (preg_match('(iPad)',$client->UserAgent)) { $agent['iPad']++; }
                                        if (preg_match('(iPod)',$client->UserAgent)) { $agent['iPod']++; }
                                        if (preg_match('(stagefright)',$client->UserAgent)) { $agent['Android']++; }
                                             
                                    } 
             
                                if ($client->FlashVersion) // Flash clients will have a different string. 
                                    { 
                                        echo $client->IpAddress.": Flash version " . $client->FlashVersion ."<BR>\n"; 
                                        $agent['Flash']++;
                                        } 
                                }   //Client Details
                            } // Detailed Loop
                    } //Client Loop
                } //Instance Loop 
            } // App Loop
        } //VHost Loop
 
    } // Count Loop
 
 
if ($geo_count) {
 
    print "<H3>Client Connections</H3>\n";
    echo "<SMALL>Last Refresh: ";
    echo $date = date("Y-m-d H:i:s");
    echo "</SMALL>\n";
 
    foreach($client_list as $client_ip) {
        $geo_record = geoip_record_by_name($client_ip);
        $cn = $geo_record['country_name'];
        $cc = strtolower($geo_record['country_code']);
        if ($cc == "us") {
            $sn = $geo_record['region'];
            $state_total[$sn]++;
            }
 
        $country_name[$cc]=$cn;
        $country_total[$cc]++;
    } //End Client iteration    
    arsort($country_total);
    print '<DIV class="countries">'."\n";
    print '<H4>Countries</H4>'."\n";
    foreach (array_keys($country_total) as $ccode) {
        print '<IMG SRC="images/flags/'.$ccode.'.png">&nbsp;';
        print "$country_name[$ccode] : ".$country_total[$ccode]."<BR>\n";
    } // End Country iteration
    print '</DIV>';
     
    arsort($state_total);
    print '<DIV class="states">'."\n";
    print '<H4>States</H4>'."\n";
    foreach (array_keys($state_total) as $state) {
        print "$state : ".$state_total[$state]."<BR>\n";
    } // End State iteration
    print '</DIV>';
 
} // End Geo Loop
 
if ($detailed) {
    $agent['iOS'] = $agent['iPhone'] + $agent ['iPad'] + $agent['iPod'];
    echo "<BR>\n";
    echo "Total HLS Clients: ". $proto['HLS']."<BR>\n";
    echo "Total Roku clients: ". $agent['Roku']."<BR>\n";
    echo "Total iOS clients: ". $agent['iOS'] ." (".$agent['iPhone']." iPhone,". $agent['iPad']." iPad,". $agent['iPod']." iPod)<BR>\n";
    echo "Total RTMP clients: ". $proto['RTMP']." (". $agent['Flash'] ." Flash)<BR>\n";
} // Detailed Loop
 
if ($simple_load) { printf("%.3f", $server_bwout); }
 
if ($simple_count) { print $server_conns; }
 
if ($stream_count) {
    print "<h3>Stream Connections</h3>\n";
    arsort($live);
    arsort($vod);
    print "<DIV CLASS=\"live\"><h4>Live</h4>\n";
        foreach (array_keys($live) as $lstr) { print strtoupper($lstr)." : ".$live[$lstr]."<BR>\n"; }
    print "</DIV><DIV CLASS=\"vod\"><h4>On-Demand</h4>\n";
        foreach (array_keys($vod) as $vstr) { print strtoupper($vstr)." : ".$vod[$vstr]."<BR>\n"; }
    print "</DIV>";
}
 
 
 
     
}
 
 
?>
Share this:
Facebook
Twitter
LinkedIn

Marcuscorrea
February 1, 2012 at 7:00 am

HI, I´m trying to use that code, I think is perfect, but is not showing the connections…
can you help me ?
http://www.clicktoservices.com:8086/connectioncounts
is working user: admin and pass: admin
Did I miss something ???
Thanks

- Ian B
  May 10, 2012 at 7:21 pm
  
  This uses a combination of connectioncounts.xml and serverinfo.xml from Andrew’s module.
  
Pedro Santiago Pito
February 26, 2012 at 7:04 pm

Can you post the code if the authentication is admin-digest?

Donatas
May 7, 2012 at 5:54 am

Hi,

Your PHP code is great, as I am not PHP coder. I have tried to use your code, but ut is not showing the connections as for Marcuscorrea

- Ian B
  May 10, 2012 at 7:24 pm
  
  check server:8086/serverinfo.xml and server:8086/connectioncounts.xml to see if you’re getting the raw data in XML.
  
Skorotych
February 6, 2013 at 7:19 am

hello, where to put php code on wowza server?

Jorge
November 9, 2015 at 10:03 am

Ian, can the code be easily modified to accommodate authentication?

Thank you!

- Ian B
  November 9, 2015 at 6:07 pm
  
  It’s just a matter of updating the HTTP request – if the simplexml function won’t do it, you can use curl and dump the output into the simplexml.

The CaNerdIan

Wowza Stats – Single Server

8 Comments On “Wowza Stats – Single Server”

Leave a Reply Cancel reply