mirror of https://github.com/limosek/zaf.git
372 lines
8.2 KiB
Bash
372 lines
8.2 KiB
Bash
|
|
# Call api function and use cache
|
|
# $1 - query string
|
|
zaf_zbxapi_do() {
|
|
local result
|
|
local query
|
|
local tmpfile
|
|
|
|
tmpfile=$ZAF_TMP_DIR/zapi$$
|
|
query="$1"
|
|
zaf_trc "Zabbix API: $query"
|
|
curl -s -f -L -X POST -H 'Content-Type: application/json-rpc' -d "$query" "$ZAF_ZBXAPI_URL" >$tmpfile
|
|
if [ $? = 0 ] && $ZAF_LIB_DIR/JSON.sh -b <$tmpfile | grep -q '"result"'; then
|
|
zaf_trc "API OK"
|
|
cat $tmpfile
|
|
rm -f $tmpfile
|
|
else
|
|
zaf_err "Error processing API request. ($?,$tmpfile)"
|
|
fi
|
|
}
|
|
# Call api function and cache results
|
|
# $1 - query string
|
|
zaf_zbxapi_do_cache() {
|
|
local result
|
|
local tmpfile
|
|
local query
|
|
|
|
query="$(echo $1 | tr '\n' ' ')"
|
|
tmpfile=$ZAF_TMP_DIR/zcapi$$
|
|
if ! zaf_fromcache "$1"; then
|
|
zaf_zbxapi_do "$1" >$tmpfile
|
|
[ -s "$tmpfile" ] && cat $tmpfile | zaf_tocache_stdin "$query" 60
|
|
rm -f $tmpfile
|
|
fi
|
|
}
|
|
|
|
# Extract one result from JSON response
|
|
zaf_zbxapi_getresult() {
|
|
$ZAF_LIB_DIR/JSON.sh -b | grep '\["result"\]' | tr '\t' ' ' | cut -d ' ' -f 2-
|
|
}
|
|
|
|
# Extract XML result from JSON response
|
|
zaf_zbxapi_getxml() {
|
|
zaf_zbxapi_getstring | zaf_strunescape '</">' | zaf_far '\\n' "\n"
|
|
}
|
|
|
|
# Extract string from JSON response result
|
|
zaf_zbxapi_getstring() {
|
|
zaf_zbxapi_getresult | sed -e 's/^"//' -e 's/"$//'
|
|
}
|
|
|
|
# Extract value from JSON response result
|
|
# $1 key
|
|
zaf_zbxapi_getvalues() {
|
|
$ZAF_LIB_DIR/JSON.sh -b | grep '\["result",.*,"'$1'"]' | tr '\t' ' ' | cut -d ' ' -f 2- | sed -e 's/^"//' -e 's/"$//'
|
|
}
|
|
|
|
# Zabbix API related functions
|
|
# Parameters in global variables ZAF_ZBX_API_*
|
|
# returns auth on stdout or false
|
|
zaf_zbxapi_login(){
|
|
local authstr
|
|
local user
|
|
local pass
|
|
local result
|
|
|
|
[ -z "$ZAF_ZBXAPI_URL" ] || [ -z "$ZAF_ZBXAPI_USER" ] || [ -z "$ZAF_ZBXAPI_PASS" ] && zaf_err "Zabbix Api parameters not set! Set ZAF_ZBXAPI_URL, ZAF_ZBXAPI_USER and ZAF_ZBXAPI_PASS and try again."
|
|
authstr='{
|
|
"method" : "user.login",
|
|
"params" : {
|
|
"password" : "'$ZAF_ZBXAPI_PASS'",
|
|
"user" : "'$ZAF_ZBXAPI_USER'"
|
|
},
|
|
"id" : 0,
|
|
"jsonrpc" : "2.0"
|
|
}'
|
|
|
|
if [ "$ZAF_ZBXAPI_AUTHTYPE" = "http" ] ; then
|
|
ZAF_ZBXAPI_URL=$(echo $ZAF_ZBXAPI_URL | cut -d '/' -f 1)//$ZAF_ZBXAPI_USER:$ZAF_ZBXAPI_PASS@$(echo $ZAF_ZBXAPI_URL | cut -d '/' -f 3-)
|
|
fi
|
|
result=$(zaf_zbxapi_do_cache "$authstr")
|
|
ZAF_ZBXAPI_AUTH=$(echo $result |zaf_zbxapi_getstring)
|
|
[ -z "$ZAF_ZBXAPI_AUTH" ] && zaf_err "Cannot login into API"
|
|
zaf_dbg "Logged into zabbix API ($ZAF_ZBXAPI_AUTH)"
|
|
}
|
|
|
|
# Get object from zabbix API
|
|
# $1 object_type
|
|
# $2 filter
|
|
# $3 params
|
|
# $4 output
|
|
# $5 id
|
|
zaf_zbxapi_get_object() {
|
|
local obj
|
|
local filter
|
|
local params
|
|
local str
|
|
local output
|
|
local id
|
|
local result
|
|
|
|
obj=$1
|
|
filter=$2
|
|
params=$3
|
|
output=$4
|
|
id=$5
|
|
[ -z "$id" ] && id=1
|
|
[ -n "$filter" ] && filter='"filter": {'$filter'},';
|
|
[ -z "$output" ] && output="shorten";
|
|
if [ -n "$params" ]; then
|
|
params='"params": {'$params', '$filter' "output":"'$output'"}';
|
|
else
|
|
params='"params": {'$filter' "output":"'$output'"}';
|
|
fi
|
|
str='{ "method": "'$obj'.get", "jsonrpc": "2.0", "auth": "'$ZAF_ZBXAPI_AUTH'",'$params', "id": "'$id'" }'
|
|
result=$(zaf_zbxapi_do_cache "$str")
|
|
[ -z "$result" ] && zaf_dbg "API call result empty or error! ($str)"
|
|
echo $result
|
|
}
|
|
|
|
# $1 hostgroup name
|
|
zaf_zbxapi_gethostgroupid() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "hostgroup" '"name": ["'$1'"]')
|
|
[ -z "$result" ] && zaf_err "HostGroup $1 not found!"
|
|
echo $result |zaf_zbxapi_getvalues groupid
|
|
}
|
|
|
|
# $1 hostid
|
|
# $2 property or null for all
|
|
zaf_zbxapi_gethost() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "host" '' '"hostids": ["'$1'"]' 'extend')
|
|
[ -z "$result" ] && zaf_err "Hostid $1 not found!"
|
|
if [ -z "$2" ]; then
|
|
echo $result
|
|
else
|
|
echo $result |zaf_zbxapi_getvalues $2
|
|
fi
|
|
}
|
|
|
|
# $1 hostname
|
|
zaf_zbxapi_gethostid() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "host" '"host": ["'$1'"]')
|
|
[ -z "$result" ] && zaf_err "Host $1 not found!"
|
|
echo $result |zaf_zbxapi_getvalues hostid
|
|
}
|
|
|
|
# $1 hostname
|
|
# $2 inv field or empty for json
|
|
zaf_zbxapi_gethostinventory() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "host" '"host": ["'$1'"]' '"withInventory": "true", "selectInventory": "extend"')
|
|
[ -z "$result" ] && zaf_err "Host $1 not found!"
|
|
if [ -z "$2" ]; then
|
|
echo $result
|
|
else
|
|
echo $result |zaf_zbxapi_getvalues $2
|
|
fi
|
|
}
|
|
|
|
# $1 hostname
|
|
zaf_zbxapi_gettemplateid() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "template" '"host": ["'$1'"]')
|
|
[ -z "$result" ] && zaf_err "Template $1 not found!"
|
|
echo $result |zaf_zbxapi_getvalues templateid
|
|
}
|
|
|
|
# $1 templateid
|
|
# $2 property or null for all
|
|
zaf_zbxapi_gettemplate() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "template" '' '"templateids": ["'$1'"]' 'extend')
|
|
[ -z "$result" ] && zaf_err "Templateid $1 not found!"
|
|
if [ -z "$2" ]; then
|
|
echo $result
|
|
else
|
|
echo $result |zaf_zbxapi_getvalues $2
|
|
fi
|
|
}
|
|
|
|
# $1 hostgroupid
|
|
zaf_zbxapi_gethostsingroup() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "host" '' '"groupids": ["'$1'"]')
|
|
[ -z "$result" ] && zaf_wrn "No hosts in groupid '$1'"
|
|
echo $result | zaf_zbxapi_getvalues "hostid"
|
|
}
|
|
|
|
# Get all hostids in system
|
|
zaf_zbxapi_gethostids() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "host")
|
|
echo $result | zaf_zbxapi_getvalues "hostid"
|
|
}
|
|
|
|
# Get all templateids in system
|
|
zaf_zbxapi_gettemplateids() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "template")
|
|
echo $result | zaf_zbxapi_getvalues "templateid"
|
|
}
|
|
|
|
# $1 hostgroupid
|
|
zaf_zbxapi_gettemplatesingroup() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "template" '' '"groupids": ["'$1'"]')
|
|
[ -z "$result" ] && zaf_wrn "No templates in groupid '$1'"
|
|
echo $result | zaf_zbxapi_getvalues "templateid"
|
|
}
|
|
|
|
# $1 map or null for all
|
|
zaf_zbxapi_getmapid() {
|
|
local result
|
|
|
|
if [ -n "$1" ]; then
|
|
result=$(zaf_zbxapi_get_object "map" '"name": ["'$1'"]')
|
|
else
|
|
result=$(zaf_zbxapi_get_object "map")
|
|
fi
|
|
[ -z "$result" ] && zaf_err "Map $1 not found"
|
|
echo $result | zaf_zbxapi_getvalues "sysmapid"
|
|
}
|
|
|
|
# $1 mapid
|
|
# $2 property or null for all
|
|
zaf_zbxapi_getmap() {
|
|
local result
|
|
|
|
result=$(zaf_zbxapi_get_object "map" '' '"sysmapids": ["'$1'"]' 'extend')
|
|
[ -z "$result" ] && zaf_err "Mapid $1 not found"
|
|
if [ -z "$2" ]; then
|
|
echo $result
|
|
else
|
|
echo $result |zaf_zbxapi_getvalues $2
|
|
fi
|
|
}
|
|
|
|
# Object backup
|
|
# $1 object
|
|
# $2 id
|
|
zaf_zbxapi_export_object(){
|
|
local bkpstr
|
|
local obj
|
|
local id
|
|
|
|
obj="$1"
|
|
id="$2"
|
|
|
|
bkpstr='
|
|
{
|
|
"method": "configuration.export",
|
|
"jsonrpc": "2.0",
|
|
"params": {
|
|
"options": {
|
|
"'$obj'": [
|
|
"'$id'"
|
|
]
|
|
},
|
|
"format": "xml"
|
|
},
|
|
"auth": "'$ZAF_ZBXAPI_AUTH'",
|
|
"id": 1
|
|
}'
|
|
zaf_zbxapi_do_cache "$bkpstr" | zaf_zbxapi_getxml
|
|
}
|
|
|
|
|
|
# Host backup
|
|
# $1 hostid
|
|
zaf_zbxapi_export_host(){
|
|
zaf_zbxapi_export_object hosts "$1"
|
|
}
|
|
|
|
# Template backup
|
|
# $1 templateid
|
|
zaf_zbxapi_export_template(){
|
|
zaf_zbxapi_export_object templates "$1"
|
|
}
|
|
|
|
# Map backup
|
|
# $1 mapid
|
|
zaf_zbxapi_export_map(){
|
|
zaf_zbxapi_export_object maps "$1"
|
|
}
|
|
|
|
# Import template into zabbix
|
|
# $1 template file or stdin
|
|
zaf_zbxapi_import_config(){
|
|
local xmlstr
|
|
local impstr
|
|
|
|
if [ -z "$1" ]; then
|
|
xmlstr=$(zaf_strescape '"')
|
|
else
|
|
! [ -f "$1" ] && return 1
|
|
xmlstr=$(zaf_strescape '"\n\r' <$1)
|
|
fi
|
|
impstr='
|
|
{
|
|
"method": "configuration.import",
|
|
"jsonrpc": "2.0",
|
|
"params": {
|
|
"format": "xml",
|
|
"rules": {
|
|
"applications": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"discoveryRules": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"graphs": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"hosts": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"items": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"templates": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"triggers": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"maps": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"screens": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"items": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
},
|
|
"valueMaps": {
|
|
"createMissing": true,
|
|
"updateExisting": true
|
|
}
|
|
},
|
|
"source": "'$xmlstr'"
|
|
},
|
|
"auth": "'$ZAF_ZBXAPI_AUTH'",
|
|
"id": 3
|
|
}'
|
|
zaf_zbxapi_do "$impstr" | zaf_zbxapi_getresult | grep -q true
|
|
}
|
|
|
|
|