Мәселенің тұжырымы
PostgreSQL сұрауларын оңтайландыру үшін белсенділік тарихын талдау мүмкіндігі, атап айтқанда, күту, құлыптау және кесте статистикасы өте қажет.
Қол жетімді мүмкіндіктер
: өте қызықты шешім, бірақ pg_stat_activity және pg_locks тарихы жоқ.
:
«Барлық жинақталған ақпарат тек жедел жадта сақталады, ал тұтынылатын жад көлемі соңғы сақталған жазбалар санымен реттеледі.
Queryid өрісі қосылды - pg_stat_statements кеңейтіміндегі бірдей сұрау идентификаторы (алдын ала орнату қажет).«
Бұл, әрине, көп көмегін тигізер еді, бірақ ең қиыны – бірінші нүкте».Барлық жинақталған ақпарат тек жедел жадта сақталады ”, яғни. мақсатты базаға әсері бар. Сонымен қатар, құлыптау тарихы мен кесте статистикасы жоқ. Анау. Шешім әдетте толық емес: «Орнату үшін дайын пакет әлі жоқ. Дереккөздерді жүктеп алып, кітапхананы өзіңіз құрастыру ұсынылады. Алдымен серверіңіз үшін «devel» бумасын орнату керек және PATH айнымалысында pg_config жолын орнату керек.«.
Тұтастай алғанда, көп әбігер бар және елеулі өндірістік деректер базасы болған жағдайда сервермен ештеңе істеу мүмкін болмауы мүмкін. Біз тағы да өзімізден бір нәрсе ойлап табуымыз керек.
Ескерту.
Көлемі өте үлкен болғандықтан және тестілеу мерзімі аяқталмағандықтан, мақала тезистер мен аралық нәтижелер жиынтығы ретінде емес, негізінен ақпараттық мақсаттарға арналған.
Толығырақ материал кейінірек, бөліктерде дайындалады
Шешімге қойылатын талаптар жобасы
Мыналарды сақтауға мүмкіндік беретін құралды әзірлеу қажет:
pg_stat_activity көру тарихы
pg_locks көрінісі арқылы сеансты құлыптау тарихы
Шешім талабы– мақсатты дерекқорға әсер етуді азайту.
Жалпы идея– деректерді жинау агенті мақсатты дерекқорда емес, жүйелік қызмет ретінде мониторинг деректер базасында іске қосылады. Иә, кейбір деректер жоғалуы мүмкін, бірақ бұл есеп беру үшін маңызды емес, бірақ жад пен дискілік кеңістік тұрғысынан мақсатты дерекқорға әсер етпейді. Ал қосылым пулын пайдаланған жағдайда пайдаланушы процестеріне әсері аз болады.
Іске асыру кезеңдері
1.Қызмет көрсету кестелері
Қолданылатын негізгі кестелерді талдауды қиындатпау үшін кестелерді сақтау үшін жеке схема қолданылады.
DROP SCHEMA IF EXISTS activity_hist ;
CREATE SCHEMA activity_hist AUTHORIZATION monitor ;
Маңызды: Схема мақсатты дерекқорда емес, мониторинг дерекқорында жасалады.
pg_stat_activity көру тарихы
Кесте pg_stat_activity көрінісінің ағымдағы суретін сақтау үшін пайдаланылады
activity_hist.history_pg_stat_activity :
--ACTIVITY_HIST.HISTORY_PG_STAT_ACTIVITY
DROP TABLE IF EXISTS activity_hist.history_pg_stat_activity;
CREATE TABLE activity_hist.history_pg_stat_activity
(
timepoint timestamp without time zone ,
datid oid ,
datname name ,
pid integer,
usesysid oid ,
usename name ,
application_name text ,
client_addr inet ,
client_hostname text ,
client_port integer,
backend_start timestamp with time zone ,
xact_start timestamp with time zone ,
query_start timestamp with time zone ,
state_change timestamp with time zone ,
wait_event_type text ,
wait_event text ,
state text ,
backend_xid xid ,
backend_xmin xid ,
query text ,
backend_type text ,
queryid bigint
);Енгізуді жылдамдату үшін - индекстер немесе шектеулер жоқ.
Тарихтың өзін сақтау үшін бөлінген кесте қолданылады:
activity_hist.archive_pg_stat_activity :
DROP TABLE IF EXISTS activity_hist.archive_pg_stat_activity;
CREATE TABLE activity_hist.archive_pg_stat_activity
(
timepoint timestamp without time zone ,
datid oid ,
datname name ,
pid integer,
usesysid oid ,
usename name ,
application_name text ,
client_addr inet ,
client_hostname text ,
client_port integer,
backend_start timestamp with time zone ,
xact_start timestamp with time zone ,
query_start timestamp with time zone ,
state_change timestamp with time zone ,
wait_event_type text ,
wait_event text ,
state text ,
backend_xid xid ,
backend_xmin xid ,
query text ,
backend_type text ,
queryid bigint
)
PARTITION BY RANGE (timepoint);Бұл жағдайда кірістіру жылдамдығына талаптар болмағандықтан, есептерді құруды жылдамдату үшін кейбір индекстер жасалды.
Сеансты блоктау тарихы
Кесте сеанс құлыптарының ағымдағы суреттерін сақтау үшін пайдаланылады:
activity_hist.history_locking :
--ACTIVITY_HIST.HISTORY_LOCKING
DROP TABLE IF EXISTS activity_hist.history_locking;
CREATE TABLE activity_hist.history_locking
(
timepoint timestamp without time zone ,
locktype text ,
relation oid ,
mode text ,
tid xid ,
vtid text ,
pid integer ,
blocking_pids integer[] ,
granted boolean
);Сондай-ақ, кірістіруді жылдамдату үшін индекстер немесе шектеулер жоқ.
Тарихтың өзін сақтау үшін бөлінген кесте қолданылады:
activity_hist.archive_locking:
DROP TABLE IF EXISTS activity_hist.archive_locking;
CREATE TABLE activity_hist.archive_locking
(
timepoint timestamp without time zone ,
locktype text ,
relation oid ,
mode text ,
tid xid ,
vtid text ,
pid integer ,
blocking_pids integer[] ,
granted boolean
)
PARTITION BY RANGE (timepoint);Бұл жағдайда кірістіру жылдамдығына талаптар болмағандықтан, есептерді құруды жылдамдату үшін кейбір индекстер жасалды.
2.Ағымдағы тарихты толтыру
Көрініс суреттерін тікелей жинау үшін plpgsql функциясын іске қосатын bash сценарийі пайдаланылады.
get_current_activity.sh
#!/bin/bash
#########################################################
#get_current_activity.sh
ERROR_FILE='/home/demon/get_current_activity'$(date +%Y%m%d-)'T'$(date +%H)$(date +%M)$(date +%S)
host=$1
s_name=$2
s_pass=$3
psql -A -t -q -v ON_ERROR_STOP=1 -c "SELECT activity_hist.get_current_activity( '$host' , '$s_name' , '$s_pass' )" >/dev/null 2>$ERROR_FILE
line_count=`cat $ERROR_FILE | wc -l`
if [[ $line_count != '0' ]];
then
rm -f /home/demon/*.err >/dev/null 2>/dev/null
cp $ERROR_FILE $ERROR_FILE'.err' >/dev/null 2>/dev/null
fi
rm $ERROR_FILE >/dev/null 2>/dev/null
exit 0plpgsql dblink функциясы мақсатты дерекқордағы көріністерге қатынасады және бақылау дерекқорындағы қызмет кестелеріне жолдарды кірістіреді.
get_current_activity.sql
CREATE OR REPLACE FUNCTION activity_hist.get_current_activity( current_host text , current_s_name text , current_s_pass text ) RETURNS BOOLEAN AS $$
DECLARE
database_rec record;
dblink_str text ;
BEGIN
EXECUTE 'SELECT dblink_connect(''LINK1'',''host='||current_host||' port=5432 dbname=postgres'||
' user='||current_s_name||' password='||current_s_pass|| ' '')';
--------------------------------------------------------------------
--GET pg_stat_activity stats
INSERT INTO activity_hist.history_pg_stat_activity
(
SELECT * FROM dblink('LINK1',
'SELECT
now() ,
datid ,
datname ,
pid ,
usesysid ,
usename ,
application_name ,
client_addr ,
client_hostname ,
client_port ,
backend_start ,
xact_start ,
query_start ,
state_change ,
wait_event_type ,
wait_event ,
state ,
backend_xid ,
backend_xmin ,
query ,
backend_type
FROM pg_stat_activity
')
AS t (
timepoint timestamp without time zone ,
datid oid ,
datname name ,
pid integer,
usesysid oid ,
usename name ,
application_name text ,
client_addr inet ,
client_hostname text ,
client_port integer,
backend_start timestamp with time zone ,
xact_start timestamp with time zone ,
query_start timestamp with time zone ,
state_change timestamp with time zone ,
wait_event_type text ,
wait_event text ,
state text ,
backend_xid xid ,
backend_xmin xid ,
query text ,
backend_type text
)
);
---------------------------------------
--ACTIVITY_HIST.HISTORY_LOCKING
INSERT INTO activity_hist.history_locking
(
SELECT * FROM dblink('LINK1',
'SELECT
now() ,
lock.locktype,
lock.relation,
lock.mode,
lock.transactionid as tid,
lock.virtualtransaction as vtid,
lock.pid,
pg_blocking_pids(lock.pid),
lock.granted
FROM pg_catalog.pg_locks lock LEFT JOIN pg_catalog.pg_database db ON db.oid = lock.database
WHERE NOT lock.pid = pg_backend_pid()
')
AS t (
timepoint timestamp without time zone ,
locktype text ,
relation oid ,
mode text ,
tid xid ,
vtid text ,
pid integer ,
blocking_pids integer[] ,
granted boolean
)
);
PERFORM dblink_disconnect('LINK1');
RETURN TRUE ;
END
$$ LANGUAGE plpgsql;Көрініс суреттерін жинау үшін systemd қызметі және екі сценарий пайдаланылады:
pg_current_activity.service
# /etc/systemd/system/pg_current_activity.service
[Unit]
Description=Collect history of pg_stat_activity , pg_locks
Wants=pg_current_activity.timer
[Service]
Type=forking
StartLimitIntervalSec=0
ExecStart=/home/postgres/pgutils/demon/get_current_activity.sh 10.124.70.40 postgres postgres
[Install]
WantedBy=multi-user.targetpg_current_activity.timer
# /etc/systemd/system/pg_current_activity.timer
[Unit]
Description=Run pg_current_activity.sh every 1 second
Requires=pg_current_activity.service
[Timer]
Unit=pg_current_activity.service
OnCalendar=*:*:0/1
AccuracySec=1
[Install]
WantedBy=timers.targetСценарийлерге құқықтарды тағайындау:
# chmod 755 pg_current_activity.taymer
# chmod 755 pg_current_activity.service
Қызметті бастайық:
# systemctl деemon-reload
# systemctl pg_current_activity.service бастау
Осылайша, көріністер тарихы секундына секундтық сурет түрінде жиналады. Әрине, егер бәрі сол күйінде қалса, кестелер өте тез ұлғаяды және көп немесе аз өнімді жұмыс мүмкін болмайды.
Мәліметтерді мұрағаттауды ұйымдастыру қажет.
3. Мұрағаттау тарихы
Мұрағаттау үшін бөлінген кестелер мұрағаты* пайдаланылады.
Жаңа бөлімдер сағат сайын жасалады, ал ескі деректер тарих* кестелерінен жойылады, сондықтан тарих* кестелерінің өлшемі көп өзгермейді және уақыт өте келе кірістіру жылдамдығы төмендемейді.
Жаңа бөлімдерді жасау plpgsql activity_hist.archive_current_activity функциясы арқылы орындалады. Жұмыс алгоритмі өте қарапайым (archive_pg_stat_activity кестесіне арналған бөлімнің мысалын пайдалану).
Жаңа бөлімді жасаңыз және толтырыңыз
EXECUTE format(
'CREATE TABLE ' || partition_name ||
' PARTITION OF activity_hist.archive_pg_stat_activity FOR VALUES FROM ( %L ) TO ( %L ) ' ,
to_char(date_trunc('year', partition_min_range ),'YYYY')||'-'||
to_char(date_trunc('month', partition_min_range ),'MM')||'-'||
to_char(date_trunc('day', partition_min_range ),'DD')||' '||
to_char(date_trunc('hour', partition_min_range ),'HH24')||':00',
to_char(date_trunc('year', partition_max_range ),'YYYY')||'-'||
to_char(date_trunc('month', partition_max_range ),'MM')||'-'||
to_char(date_trunc('day', partition_max_range ),'DD')||' '||
to_char(date_trunc('hour', partition_max_range ),'HH24')||':00'
);
INSERT INTO activity_hist.archive_pg_stat_activity
(
SELECT *
FROM activity_hist.history_pg_stat_activity
WHERE timepoint BETWEEN partition_min_range AND partition_max_range
);Индекстерді құру
EXECUTE format (
'CREATE INDEX '||index_name||
' ON '||partition_name||' ( wait_event_type , backend_type , timepoint )'
);
EXECUTE format ('CREATE INDEX '||index_name||
' ON '||partition_name||' ( wait_event_type , backend_type , timepoint , queryid )'
);History_pg_stat_activity кестесінен ескі деректерді жою
DELETE
FROM activity_hist.history_pg_stat_activity
WHERE timepoint < partition_max_range;Әрине, мезгіл-мезгіл ескі бөлімдер қажетсіз деп жойылады.
Негізгі есептер
Шындығында, мұның бәрі не үшін жасалып жатыр? Oracle AWR-ді өте анық емес еске түсіретін есептерді алу үшін.
Есептерді алу үшін pg_stat_activity және pg_stat_statements көріністері арасында байланыс орнату қажет екенін қосу маңызды. Кестелер "history_pg_stat_activity", "archive_pg_stat_activity" кестелеріне "queryid" бағанын қосу арқылы байланыстырылады. Баған мәнін қосу әдісі осы мақаланың ауқымынан тыс және мұнда сипатталған − .
СҰРАУЛАР ҮШІН ЖАЛПЫ CPU УАҚЫТЫ
Сұраныс:
WITH hist AS
(
SELECT
aa.query ,aa.queryid ,
count(*) * interval '1 second' AS duration
FROM activity_hist.archive_pg_stat_activity aa
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND backend_type = 'client backend' AND datname != 'postgres' AND ( aa.wait_event_type IS NULL ) ANDaa.state = 'active'
GROUP BY aa.wait_event_type , aa.wait_event , aa.query ,aa.queryid
UNION
SELECT
ha.query ,ha.queryid,
count(*) * interval '1 second' AS duration
FROM activity_hist.history_pg_stat_activity_for_reports ha
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND backend_type = 'client backend' AND datname != 'postgres' AND ( ha.wait_event_type IS NULL )AND ha.state = 'active'
GROUP BY ha.wait_event_type , ha.wait_event , ha.query ,ha.queryid
)
SELECT query , queryid , SUM( duration ) as duration
FROM hist
GROUP BY query , queryid
ORDER BY 3 DESCМысал:
-------------------------------------------------------------------
| TOTAL CPU TIME FOR QUERIES : 07:47:36
+----+----------------------------------------+--------------------
| #| queryid| duration
+----+----------------------------------------+--------------------
| 1| 389015618226997618| 04:28:58
| 2| | 01:07:29
| 3| 1237430309438971376| 00:59:38
| 4| 4710212362688288619| 00:50:48
| 5| 28942442626229688| 00:15:50
| 6| 9150846928388977274| 00:04:46
| 7| -6572922443698419129| 00:00:06
| 8| | 00:00:01
+----+----------------------------------------+--------------------
СҰРАУЛАРДЫ КҮТУ УАҚЫТЫ
Сұраныс:
WITH hist AS
(
SELECT
aa.query ,aa.queryid ,
count(*) * interval '1 second' AS duration
FROM activity_hist.archive_pg_stat_activity aa
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
( aa.wait_event_type IS NOT NULL )
GROUP BY aa.wait_event_type , aa.wait_event , aa.query ,aa.queryid
UNION
SELECT
ha.query ,ha.queryid,
count(*) * interval '1 second' AS duration
FROM activity_hist.history_pg_stat_activity_for_reports ha
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
( ha.wait_event_type IS NOT NULL )
GROUP BY ha.wait_event_type , ha.wait_event , ha.query ,ha.queryid
)
SELECT query , queryid , SUM( duration ) as duration
FROM hist
GROUP BY query , queryid
ORDER BY 3 DESC Мысал:
-------------------------------------------------------------------
| TOTAL WAITINGS TIME FOR QUERIES : 21:55:04
+----+----------------------------------------+--------------------
| #| queryid| duration
+----+----------------------------------------+--------------------
| 1| 389015618226997618| 16:19:05
| 2| | 03:47:04
| 3| 8085340880788646241| 00:40:20
| 4| 4710212362688288619| 00:13:35
| 5| 9150846928388977274| 00:12:25
| 6| 28942442626229688| 00:11:32
| 7| 1237430309438971376| 00:09:45
| 8| 2649515222348904837| 00:09:37
| 9| | 00:03:45
| 10| 3167065002719415275| 00:02:20
| 11| 5731212217001535134| 00:02:13
| 12| 8304755792398128062| 00:01:31
| 13| 2649515222348904837| 00:00:59
| 14| 2649515222348904837| 00:00:22
| 15| | 00:00:12
| 16| 3422818749220588372| 00:00:08
| 17| -5730801771815999400| 00:00:03
| 18| -1473395109729441239| 00:00:02
| 19| 2404820632950544954| 00:00:02
| 20| -6572922443698419129| 00:00:02
| 21| 2369289265278398647| 00:00:01
| 22| 180077086776069052| 00:00:01
+----+----------------------------------------+--------------------
СҰРАУЛАРДЫ КҮТЕМІЗ
Сұраулар:
WITH hist AS
(
SELECT
aa.wait_event_type , aa.wait_event
FROM activity_hist.archive_pg_stat_activity aa
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
aa.wait_event IS NOT NULL
GROUP BY aa.wait_event_type , aa.wait_event
UNION
SELECT
ha.wait_event_type , ha.wait_event
FROM activity_hist.history_pg_stat_activity_for_reports ha
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
ha.wait_event IS NOT NULL
GROUP BY ha.wait_event_type , ha.wait_event
)
SELECT wait_event_type , wait_event
FROM hist
GROUP BY wait_event_type , wait_event
ORDER BY 1 ASC,2 ASC
----------------------------------------------------------------------
WITH hist AS
(
SELECT
aa.wait_event_type , aa.wait_event , aa.query ,aa.queryid ,
count(*) * interval '1 second' AS duration
FROM activity_hist.archive_pg_stat_activity aa
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
( aa.wait_event_type = waitings_stat_rec.wait_event_type AND aa.wait_event = waitings_stat_rec.wait_event )
GROUP BY aa.wait_event_type , aa.wait_event , aa.query ,aa.queryid
UNION
SELECT
ha.wait_event_type , ha.wait_event , ha.query ,ha.queryid,
count(*) * interval '1 second' AS duration
FROM activity_hist.history_pg_stat_activity_for_reports ha
WHERE timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
backend_type = 'client backend' AND datname != 'postgres' AND
( ha.wait_event_type = waitings_stat_rec.wait_event_type AND ha.wait_event = waitings_stat_rec.wait_event )
GROUP BY ha.wait_event_type , ha.wait_event , ha.query ,ha.queryid
)
SELECT query , queryid , SUM( duration ) as duration
FROM hist
GROUP BY query , queryid
ORDER BY 3 DESCМысал:
------------------------------------------------
| WAITINGS FOR QUERIES
+-----------------------------------------------
| wait_event_type = Client|
| wait_event = ClientRead|
| Total time = 00:46:56|
------------------------------------------------
| #| queryid| duration
+-----+--------------------+--------------------
| 1| 8085340880788646241| 00:40:20
| 2| | 00:03:45
| 3| 5731212217001535134| 00:01:53
| 4| | 00:00:12
| 5| 9150846928388977274| 00:00:09
| 6| 3422818749220588372| 00:00:08
| 7| 1237430309438971376| 00:00:06
| 8| 28942442626229688| 00:00:05
| 9| 4710212362688288619| 00:00:05
| 10|-5730801771815999400| 00:00:03
| 11| 8304755792398128062| 00:00:02
| 12|-6572922443698419129| 00:00:02
| 13|-1473395109729441239| 00:00:02
| 14| 2404820632950544954| 00:00:02
| 15| 180077086776069052| 00:00:01
| 16| 2369289265278398647| 00:00:01
+-----------------------------------------------
| wait_event_type = IO|
| wait_event = BufFileRead|
| Total time = 00:00:38|
------------------------------------------------
| #| queryid| duration
+-----+--------------------+--------------------
| 1| 28942442626229688| 00:00:38
+-----------------------------------------------
ҚҰЛЫПТАЛҒАН ПРОЦЕСТЕР ТАРИХЫ
Сұраныс:
SELECT
MIN(date_trunc('second',timepoint)) AS started ,
count(*) * interval '1 second' as duration ,
pid , blocking_pids , relation , mode , locktype
FROM
activity_hist.archive_locking al
WHERE
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
NOT granted AND
locktype = 'relation'
GROUP BY pid , blocking_pids , relation , mode , locktype
UNION
SELECT
MIN(date_trunc('second',timepoint)) AS started ,
count(*) * interval '1 second' as duration ,
pid , blocking_pids , relation , mode , locktype
FROM
activity_hist.history_locking
WHERE
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
NOT granted AND
locktype = 'relation'
GROUP BY pid , blocking_pids , relation , mode , locktype
ORDER BY 1Мысал:
------------------------------------------------- ------------------------------------------------- -------------------------------- | ҚҰЛЫПТАЛҒАН ПРОЦЕСТЕР ТАРИХЫ +-----+----------+-----+-------- --+------------ --------+--------------------+----- --------------- +------------------- | #| pid| басталды| ұзақтығы| blocking_pids| қатынас| режим| locktype +----------+----------+-----+---------- +--------- -----------+-----------+------- -------------+----- -------------- | 1| 26224| 2019-09-02 19:32:16| 00:01:45| {26211}| 16541| AccessShareLock| қатынасы | 2| 26390| 2019-09-02 19:34:03| 00:00:53| {26211}| 16541| AccessShareLock| қатынасы | 3| 26391| 2019-09-02 19:34:03| 00:00:53| {26211}| 16541| AccessShareLock| қатынасы | 4| 26531| 2019-09-02 19:35:27| 00:00:12| {26211}| 16541| AccessShareLock| қатынасы | 5| 27284| 2019-09-02 19:44:02| 00:00:19| {27276}| 16541| AccessShareLock| қатынасы | 6| 27283| 2019-09-02 19:44:02| 00:00:19| {27276}| 16541| AccessShareLock| қатынасы | 7| 27286| 2019-09-02 19:44:02| 00:00:19| {27276}| 16541| AccessShareLock| қатынасы | 8| 27423| 2019-09-02 19:45:24| 00:00:12| {27394}| 16541| AccessShareLock| қатынасы | 9| 27648| 2019-09-02 19:48:06| 00:00:20| {27647}| 16541| AccessShareLock| қатынасы | 10| 27650| 2019-09-02 19:48:06| 00:00:20| {27647}| 16541| AccessShareLock| қатынасы | 11| 27735| 2019-09-02 19:49:08| 00:00:06| {27650}| 16541| AccessExclusiveLock| қатынасы | 12| 28380| 2019-09-02 19:56:03| 00:01:56| {28379}| 16541| AccessShareLock| қатынасы | 13| 28379| 2019-09-02 19:56:03| 00:00:01| 28377| 16541| AccessExclusiveLock| қатынасы | | | | | 28376| |
ПРОЦЕСТЕР ТАРИХЫН БӨЛГЕУ
Сұраулар:
SELECT
blocking_pids
FROM
activity_hist.archive_locking al
WHERE
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
NOT granted AND
locktype = 'relation'
GROUP BY blocking_pids
UNION
SELECT
blocking_pids
FROM
activity_hist.history_locking
WHERE
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour') AND
NOT granted AND
locktype = 'relation'
GROUP BY blocking_pids
ORDER BY 1
---------------------------------------------------------------
SELECT
pid , usename , application_name , datname ,
MIN(date_trunc('second',timepoint)) as started ,
count(*) * interval '1 second' as duration ,
state ,
query
FROM activity_hist.archive_pg_stat_activity
WHERE pid= current_pid AND
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour')
GROUP BY pid , usename , application_name ,
datname ,
state_change,
state ,
query
UNION
SELECT
pid , usename , application_name , datname ,
MIN(date_trunc('second',timepoint)) as started ,
count(*) * interval '1 second' as duration ,
state ,
query
FROM activity_hist.history_pg_stat_activity_for_reports
WHERE pid= current_pid AND
timepoint BETWEEN pg_stat_history_begin+(current_hour_diff * interval '1 hour') AND pg_stat_history_end+(current_hour_diff * interval '1 hour')
GROUP BY pid , usename , application_name ,
datname ,
state_change,
state ,
query
ORDER BY 5 , 1Мысал:
------------------------------------------------- ------------------------------------------------- ------------------------------------------------- ----------------------- БҰҚАУ ПРОЦЕСТЕР ТАРИХЫН +----+----------+------- ---+-------------------+----------+-------------- ------------+--------------------+---------------- ----- --------+------------------------------------ --- | #| pid| usename| қолданба_атауы| datname| басталды| ұзақтығы| күй| сұрау +----------+----------+----------+-----+ --------- -+-------------------+------------------ --+------ ----------------------------------+---------------- ------- ----------------- | 1| 26211| тусер| psql| tdb1| 2019-09-02 19:31:54| 00:00:04| бос| | 2| 26211| тусер| psql| tdb1| 2019-09-02 19:31:58| 00:00:06| транзакцияда бос| БАСТА; | 3| 26211| тусер| psql| tdb1| 2019-09-02 19:32:16| 00:01:45| транзакцияда бос| құлыптау кестесі wafer_data; | 4| 26211| тусер| psql| tdb1| 2019-09-02 19:35:54| 00:01:23| бос| міндеттеу; | 5| 26211| тусер| psql| tdb1| 2019-09-02 19:38:46| 00:00:02| транзакцияда бос| БАСТА; | 6| 26211| тусер| psql| tdb1| 2019-09-02 19:38:54| 00:00:08| транзакцияда бос| құлыптау кестесі wafer_data; | 7| 26211| тусер| psql| tdb1| 2019-09-02 19:39:08| 00:42:42| бос| міндеттеу; | 8| 26211| тусер| psql| tdb1| 2019-09-03 07:12:07| 00:00:52| белсенді| test_del() таңдау;
Даму.
Көрсетілген негізгі сұраулар және алынған есептер өнімділік оқиғаларын талдау кезінде өмірді әлдеқайда жеңілдетеді.
Негізгі сұрауларға сүйене отырып, Oracle AWR-ге анық ұқсамайтын есепті алуға болады.
Жиынтық есептің мысалы
+------------------------------------------------ ---------------------------------- | ҚЫЗМЕТ ЖӘНЕ КҮТІЛЕР БОЙЫНША ШОҒЫРЫЛҒАН ЕСЕП.
Жалғасы бар. Келесі кезекте құлыптау тарихын жасау (pg_stat_locks), кестелерді толтыру процесінің егжей-тегжейлі сипаттамасы.
Ақпарат көзі: www.habr.com