---
title: VMware GreenplumをWavefrontでモニタリングするメモ
tags: ["OrbStack", "Greenplum", "Wavefront", "Telegraf", "Greenplum Command Center", "Tanzu", "PostgreSQL", "Rocky"]
categories: ["Middleware", "RDBMS", "Greenplum", "Wavfront"]
date: 2024-06-14T04:40:01Z
updated: 2024-06-14T04:40:01Z
---

前提条件として、次の3つがインストールされている必要があります。

* [VMware Greenplum](/entries/764)
* [VMware Greenplum Command Center](/entries/797)
* [Wavefront Proxy](/entries/795)




### TelegrafをCoordinator上にインストール

```
curl -s https://packagecloud.io/install/repositories/wavefront/telegraf/script.rpm.sh | sudo bash
sudo yum install telegraf -y
```

```toml
cat <<EOF | sudo tee -a /etc/telegraf/telegraf.d/10-wavefront.conf
[[outputs.wavefront]]
url = "http://wf-proxy.orb.local:2878"
metric_separator = "."
source_override = ["proxyname", "agent_host", "node_host"]
convert_paths = true
EOF
```

### TelegrafでGreenplumをモニタリング

```toml
cat <<'EOF' | sudo tee -a /etc/telegraf/telegraf.d/greenplum.conf

[[inputs.postgresql_extensible]]
name_prefix = "greenplum."
# specify address via a url matching:
# postgres://[user[:password]]@localhost[/dbname]?sslmode=...
# or a simple string:
#   host=localhost user=gpadmin password=... sslmode=... dbname=gpperfmon
#
# All connection parameters are optional.  
# Without the dbname parameter, the driver will default to a database
# with the same name as the user. This dbname is just for instantiating a
# connection with the server and doesn't restrict the databases we are trying
# to grab metrics for.
# 
address = "postgres://gpadmin@localhost/gpperfmon"

# The parameter host specifies the IP address of master host of Greenplum.
# The parameter port specifies the port in which the Greenplum database is configured. It is 5432 by default.
# A list of databases to pull metrics about. If not specified, metrics for all
# databases are gathered.
# databases = ["app_production", "testing"]

## Whether to use prepared statements when connecting to the database.
## This should be set to false when connecting through a PgBouncer instance
## with pool_mode set to transaction.
prepared_statements = false

# Define the toml config where the sql queries are stored.
# New queries can be added, if the withdbname is set to true and there is no
# databases defined in the 'databases field', the sql query is ended by a 'is
# not null' in order to make the query succeed.
# Be careful that the sqlquery must contain the where clause with a part of
# the filtering, the plugin will add a 'IN (dbname list)' clause if the
# withdbname is set to true
# Example :
# The sqlquery : "SELECT * FROM pg_stat_database where datname" become
# "SELECT * FROM pg_stat_database where datname IN ('postgres', 'pgbench')"
# because the databases variable was set to ['postgres', 'pgbench' ] and the
# withdbname was true.
# Be careful that if the withdbname is set to false, you don't have to define
# the where clause (aka with the dbname).
#
# The tagvalue field is used to define custom tags (separated by commas).
# The query is expected to return columns which match the names of the
# defined tags. The values in these columns must be of a string-type,
# a number-type or a blob-type.
[inputs.postgresql_extensible.tags]
cluster_name = "orbstack"
# The parameter cluster_name specifies a unique name for the Greenplum integration.
#
# Structure :
# [[inputs.postgresql_extensible.query]]
# sqlquery string
# version string
# withdbname boolean
# tagvalue string (coma separated)
# timestamp string
# Query Metrics
[[inputs.postgresql_extensible.query]]
sqlquery = "select ctime::timestamptz at time zone 'UTC' as currtime, queries_total, queries_finished, queries_blocked, queries_running, queries_queued from gpmetrics.gpcc_database_history where ctime::timestamptz between NOW() - INTERVAL '1 minutes' and NOW()"
version = 803
withdbname = false
timestamp = "currtime"
# Memory Metrics
[[inputs.postgresql_extensible.query]]
sqlquery = "select ctime::timestamptz at time zone 'UTC' as currtime, total_bytes, bytes_used, bytes_available,hostname, filesystem from gpmetrics.gpcc_disk_history where ctime::timestamptz between NOW() - INTERVAL '1 minutes' and NOW()"
version = 803
withdbname = false
tagvalue = "hostname,filesystem"
timestamp = "currtime"
# Segment Metrics
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as upsegments from pg_catalog.gp_segment_configuration where status = 'u' and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as downsegments from pg_catalog.gp_segment_configuration where status = 'd' and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as preferred_role from pg_catalog.gp_segment_configuration where role = preferred_role and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as nonpreferred_role from pg_catalog.gp_segment_configuration where role != preferred_role and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as mode_synced from pg_catalog.gp_segment_configuration where mode = 's' and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*) as mode_nonsynced from pg_catalog.gp_segment_configuration where mode != 's' and content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(distinct hostname) as segment_hosts from pg_catalog.gp_segment_configuration where content != -1"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select extract(epoch from now()-pg_postmaster_start_time()) as uptime"
version = 803
withdbname = false
tagvalue = ""
[[inputs.postgresql_extensible.query]]
sqlquery = "select case when (status = 'u') then 1 else 0 end as status, case when (mode = 's') then 'Synced' else 'Non Synced' end as mode, case when (role = 'p') then 'Primary' else 'Mirror' end as role, case when (preferred_role = 'p') then 'Primary' else 'Mirror' end as preferred_role, address, port, dbid, hostname, content from pg_catalog.gp_segment_configuration where content != -1"
version = 803
withdbname = false
tagvalue = "hostname,port,address,role,preferred_role,dbid,mode,content"
[[inputs.postgresql_extensible.query]]
sqlquery = "select count(*)-1 as connections from pg_stat_activity"
version = 803
withdbname = false
tagvalue = ""
# Host Metrics
[[inputs.postgresql_extensible.query]]
sqlquery="select ctime::timestamptz at time zone 'UTC' as currtime, hostname, cpu_user, cpu_sys, cpu_iowait, cpu_idle, disk_rb_rate, disk_wb_rate, disk_ro_rate, disk_wo_rate, net_rb_rate, net_wb_rate, net_rp_rate, net_wp_rate, load0, load1, load2, swap_total, swap_used, swap_page_in, swap_page_out, quantum from gpmetrics.gpcc_system_history where ctime::timestamptz between NOW() - INTERVAL '1 minutes' and NOW()"
version=803
withdbname=false
tagvalue="hostname"
timestamp="currtime"

EOF
```

```
sudo service telegraf start
```

### WavefrontにGreenplumのダッシュボードをインストール

https://docs.wavefront.com/greenplum.html

"Integrations" -> "VMware Tanzu Greenplum"

<img width="1024" alt="image" src="https://github.com/making/blog.ik.am/assets/106908/79e4b3b3-ef17-43ed-83a5-cfdaf3609c37">

<img width="1024" alt="image" src="https://github.com/making/blog.ik.am/assets/106908/84aeb03b-0cc5-4514-b0df-a4003d78cfa7">

<img width="871" alt="image" src="https://github.com/making/blog.ik.am/assets/106908/51fcc60f-d6cc-4486-af66-e996f0aa2baf">

<img width="1800" alt="image" src="https://github.com/making/blog.ik.am/assets/106908/49d3e081-e207-4862-97bf-67786ab21454">

<img width="1790" alt="image" src="https://github.com/making/blog.ik.am/assets/106908/f7eb30ee-3c71-4467-917c-939cfb31e403">