zabbix/limosek-zaf-plugins
1
0
Fork 0
mirror of https://github.com/limosek/zaf-plugins.git synced 2025-10-31 17:47:37 +01:00
Code Issues Releases Wiki Activity

CSV fields are counted from 1

Browse Source
This commit is contained in:
2017-02-14 18:17:46 +01:00
parent c32c2bcca4
commit a41faae3f0
4 changed files with 126 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -1 +1,2 @@
*~
/nbproject/private/

72
csv/discovery Normal file
View File

@@ -0,0 +1,72 @@
#!/usr/bin/php
<?php
require_once(__DIR__."/functions.inc.php");
if ($argc<6) {
fprintf(STDERR,"Missing arguments!\n");
fprintf(STDERR,"send file.csv delim mode hostfield [item1=field1] [item2=field2] ...\n");
fprintf(STDERR,"mode is stdout or send,\n");
fprintf(STDERR,"hostfield is host for item to send,\n");
fprintf(STDERR,"itemx is key for item to send,\n");
fprintf(STDERR,"fieldx is data to send send,\n");
fprintf(STDERR,"In hostfield, itemx and fieldx are replaced this macros:\n");
fprintf(STDERR,"{COLUMN:x} is replaced by value of column x\n");
fprintf(STDERR,"{column:x} is replaced by lowercased value of column x\n");
fprintf(STDERR,"x can be column index (x starts with zero) or header name.\n");
fprintf(STDERR,"CSV must include header line.\n\n");
exit(1);
}
$csv=$argv[1];
if ($csv=="-") {
$csv="php://stdin";
}
$delim=$argv[2];
$mode=$argv[3];
$host=$argv[4];
$items=Array();
for ($i=5;$i<$argc;$i++) {
List($key,$field)=preg_split("/=/",$argv[$i]);
$items[]=Array(
"key" => $key,
"field" => $field
);
}
$c=fopen($csv,"r");
$header=fgetcsv($c,false,$delim);
$data="";
while ($row=fgetcsv($c,false,$delim)) {
if (count($row)==1 && trim($row[0])=="") continue;
$p=get_replacements($header,$row);
$hostr=preg_replace($p["patterns"],$p["replacements"],$host);
foreach ($items as $item) {
$data.=sprintf("%s %s %s\n",
$hostr,
preg_replace($p["patterns"],$p["replacements"],$item["key"]),
addcslashes(preg_replace($p["patterns"],$p["replacements"],$item["field"]),"\0..\40\"")
);
}
}
fclose($c);
if ($mode=="send") {
$h = popen(getenv("ZAF_BIN")." send", "w");
fputs($h,$data);
fclose($h);
exit;
}
if ($mode=="stdout") {
echo $data;
exit;
}
fprintf(STDERR,"Bad mode $mode\n!");
exit(1);

6
csv/get_fields.php
View File

@@ -1,6 +1,5 @@
#!/usr/bin/php
<?php
require_once(__DIR__ . "/functions.inc.php");
$csv = getenv("csv");
@@ -18,9 +17,10 @@ $last1=end($header);
$last2 = end($range);
foreach ($header as $num => $column) {
if (!array_key_exists($num,$range)) continue;
if (!array_key_exists($num, $range))
continue;
json_row();
json_column("COLUMN",$num);
json_column("COLUMN", $num+1);
json_column("NAME", addslashes($column), true);
json_row_end($last1 == $column || $last2 == ($num + 1));
}

27
csv/get_rows.php
View File

@@ -1,6 +1,5 @@
#!/usr/bin/php
<?php
require_once(__DIR__ . "/functions.inc.php");
$csv = getenv("csv");
@@ -13,13 +12,17 @@ $delim=getenv("delimiter");
$c = fopen($csv, "r");
if ($head) {
$header=fgetcsv($c,false,$delim);
} else {
$header = Array();
$i=0;
$i = 1;
if ($head) {
$h = fgetcsv($c, false, $delim);
foreach ($h as $val) {
$header[$i] = $val;
$i++;
}
} else {
foreach ($range as $r) {
$header[$i]=sprintf("FIELD%d",$i);
$header[$i] = sprintf("FIELD%d", $i + 1);
$i++;
}
}
@@ -28,18 +31,20 @@ json_init();
$line = 0;
$last = end($range);
$lastrow = max($rows);
$numrows = intval(exec("wc -l '$csv'"));
while ($row = fgetcsv($c, false, $delim)) {
$line++;
if (!array_key_exists($line,$rowsf)) continue;
if (!array_key_exists($line, $rowsf))
continue;
json_row();
json_column("ROW", "$line");
foreach ($range as $num) {
$col=$num-1;
foreach ($range as $col) {
json_column("COLUMN$col", $header[$col]);
json_column("VALUE$col",addslashes($row[$col]),$last==$num);
json_column("VALUE$col", addslashes($row[$col - 1]), $last == $col);
}
json_row_end(feof($c)||$line==$lastrow);
echo feof($c);
json_row_end(feof($c) || $line == $lastrow || $line == $numrows-1);
}
json_end();