|
Hello,
I have multiple HAProxy servers that we load balance with IPVS, and I
wanted the ability to natively health check them using the CSV stats
page, rather than just using the http service check, as this would
require a separate health check configuration and port for each
server/service that we proxy. This configuration quickly gets
unwieldy. I figured that I could use the one single location CSV stats
page to service check all the servers we proxy.
Once this patch is applied, you will need the Text:CSV perl module for
the service check to function.
http://search.cpan.org/~makamaka/Text-CSV-1.21/
To configure ldirectord to service check HAProxy, set the service line
to haproxy, the checkport to the port that the HAProxy stats page is
listening on, the request line to the relative URI for the HAProxy CSV
stats page and finally set the receive line to the proxy, service and
status to check in the CSV output. These three entries correspond to
the "pxname", "svname" and "status" fields respectively (see
documentation link below). Anything that appears in the HAProxy CSV
stats page in those fields can be entered in the receive line.
Here is an example of what the HAProxy CSV stats page looks like for reference:
http://demo.1wt.eu/;csv
And, some documentation on the HAProxy stats page:
http://cbonte.github.com/haproxy-dconv/configuration-1.4.html#9
So a configuration would look as follows:
service = haproxy
checkport = 80
request = "/;csv"
receive = "www,bck,UP"
This would check the stats of the "www" proxy, the "bck" service and
if the status is "UP".
I'm open to any comments, or suggestions. Also, if you feel that this
feature is beneficial I would appreciate if it was merged into the
ldirectord mainline. The CSV stats are very extensive, so this patch
could be expanded in numerous ways if anyone is inclined.
I've also CC'd the HAProxy mailing list in case anyone on that list
uses ldirectord and would find this patch useful.
Thanks.
--- /usr/sbin/ldirectord 2012-04-27 05:40:43.000000000 -0600
+++ /usr/sbin/ldirectord_haproxy 2012-12-27 11:16:44.570384155 -0700
@@ -448,7 +448,7 @@
On means no checking will take place and real servers will always be
activated. Default is I<negotiate>.
-B<service = >B<dns> | B<ftp> | B<http> | B<https> | B<http_proxy> |
B<imap> | B<imaps> | B<ldap> | B<mysql> | B<nntp> | B<none> |
B<oracle> | B<pgsql> | B<pop> | B<pops> | B<radius> | B<simpletcp> |
B<sip> | B<smtp> | B<submission>
+B<service = >B<dns> | B<ftp> | B<haproxy> | B<http> | B<https> |
B<http_proxy> | B<imap> | B<imaps> | B<ldap> | B<mysql> | B<nntp> |
B<none> | B<oracle> | B<pgsql> | B<pop> | B<pops> | B<radius> |
B<simpletcp> | B<sip> | B<smtp> | B<submission>
The type of service to monitor when using checktype=negotiate. None denotes
a service that will not be monitored.
@@ -535,6 +535,9 @@
Number of port to monitor. Sometimes check port differs from service port.
+If the service is HAProxy, the checkport must be set to the port that
+HAProxy stats page is listening on.
+
Default: port specified for each real server
B<request = ">I<uri to requested object>B<">
@@ -557,6 +560,9 @@
For a simpletcp check, this string is sent verbatim except any occurrences
of \n are replaced with a new line character.
+For a HAProxy check, this string should be the relative URI for the HAProxy
+CSV stats page.
+
B<receive = ">I<regexp to compare>B<">
If the requested result contains this I<regexp to compare>, the real server
@@ -570,6 +576,11 @@
For a MySQL check, the receive setting is not used.
+For a HAProxy check, this should be the proxy, service and status to check.
+It should be in the format "proxy,service,status". These correspond to
+the "pxname", "svname" and "status" CSV fields respectively. Anything that
+appears in the HAProxy CSV stats page in those fields can be entered here.
+
B<httpmethod = GET> | B<HEAD>
Sets the HTTP method which should be used to fetch the URI specified in
@@ -1490,6 +1501,7 @@
} elsif ($rcmd =~ /^service\s*=\s*(.*)/) {
$1 =~ /(\w+)/ && ($1 eq "dns" ||
$1 eq "ftp" ||
+ $1 eq "haproxy" ||
$1 eq "http" ||
$1 eq "https" ||
$1 eq "http_proxy"
||
@@ -1511,6 +1523,7 @@
or &config_error($line,
"service must " .
"be dns, ftp, " .
+ "haproxy, " .
"http, https, " .
"http_proxy, " .
"imap, imaps, " .
@@ -2729,6 +2742,8 @@
$$r{num_connects} = 0 if (check_oracle($v, $r) ==
$SERVICE_UP);
} elsif ($$v{service} eq "simpletcp") {
$$r{num_connects} = 0 if (check_simpletcp($v, $r) ==
$SERVICE_UP);
+ } elsif ($$v{service} eq "haproxy") {
+ $$r{num_connects} = 0 if (check_haproxy($v, $r) ==
$SERVICE_UP);
} else {
$$r{num_connects} = 0 if (check_none($v, $r) ==
$SERVICE_UP);
}
@@ -3640,6 +3655,83 @@
return $SERVICE_DOWN;
}
+sub check_haproxy
+{
+ use LWP::Simple;
+ use Text::CSV;
+
+ my ($v, $r) = @_;
+ my $port = $$v{checkport};
+ my @haproxy_fields = split(",", lc($$r{receive}));
+ my $not_found = 0;
+
+ if (!defined($port)) {
+ &ld_debug(2, "The checkport line is not configured and must be
set
when using haproxy as the service.");
+ &ld_debug(2, "Configure the port that the haproxy stats page is
listening on to service check proxied servers.");
+
+ service_set($v, $r, "down", {do_log => 1});
+ return $SERVICE_DOWN;
+ }
+
+ if (!defined($haproxy_fields[0]) or !defined($haproxy_fields[1]) or
!defined($haproxy_fields[2])) {
+ &ld_debug(2, "The receive line is not configured correctly, or
at all.");
+ &ld_debug(2, "Use the format receive = \"proxy,service,status\"
when using haproxy as the service.");
+
+ service_set($v, $r, "down", {do_log => 1});
+ return $SERVICE_DOWN;
+ }
+
+ &ld_debug(2, "Checking $$v{service} stats at:
http://$$r{server}:$port$$r{request}";);
+
+ &ld_debug(2, "Checking proxy: \"$haproxy_fields[0]\" service:
\"$haproxy_fields[1]\" for status: \"$haproxy_fields[2]\"");
+
+ my $csv = Text::CSV->new({
+ binary => 1
+ });
+
+ my $csv_file = get('http://' . $$r{server} . ':' . $port .
$$r{request});
+
+ open (CSV, "<", \$csv_file);
+
+ while (<CSV>) {
+ next if ($. == 1);
+
+ if ($csv->parse($_)) {
+ my @columns = $csv->fields();
+
+ @columns = map {lc} @columns;
+
+ if ($columns[0] eq $haproxy_fields[0]) {
+ if ($columns[1] eq $haproxy_fields[1]) {
+ if ($columns[17] eq $haproxy_fields[2])
{
+ &ld_debug(2, "Status of
\"$haproxy_fields[2]\" found for proxy:
\"$columns[0]\" and service: \"$columns[1]\"");
+
+ close CSV;
+ service_set($v, $r, "up",
{do_log => 1});
+ return $SERVICE_UP;
+ }
+ }
+ }
+ }
+
+ $not_found = 1;
+ }
+
+ close CSV;
+
+ if ($not_found eq 1) {
+ &ld_debug(2, "Proxy: \"$haproxy_fields[0]\" service:
\"$haproxy_fields[1]\" or status: \"$haproxy_fields[2]\" not found.");
+
+ } else {
+ &ld_debug(2, "Unable to retrieve $$v{service} stats at:
http://$$r{server}:$port$$r{request}";);
+ }
+
+ &ld_debug(2, "Verify your checkport, request and receive
configuration settings.");
+
+ service_set($v, $r, "down", {do_log => 1});
+ return $SERVICE_DOWN;
+}
+
# check_none
# Dummy function to check service if service type is none.
# Just activates the real server
--
To unsubscribe from this list: send the line "unsubscribe lvs-devel" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
|
