ការបង្កើតបញ្ហា

ដើម្បីបង្កើនប្រសិទ្ធភាពសំណួរ PostgreSQL សមត្ថភាពក្នុងការវិភាគប្រវត្តិសកម្មភាព ជាពិសេស ការរង់ចាំ ការចាក់សោ និងស្ថិតិតារាងគឺត្រូវបានទាមទារយ៉ាងខ្លាំង។

ឱកាសដែលមាន

ឧបករណ៍វិភាគបន្ទុកប្រវត្តិសាស្ត្រ ឬ "AWR សម្រាប់ Postgres"៖ ជាដំណោះស្រាយគួរឱ្យចាប់អារម្មណ៍ ប៉ុន្តែមិនមានប្រវត្តិនៃ pg_stat_activity និង pg_locks ទេ។

ផ្នែកបន្ថែម pgsentinel :
«ព័ត៌មានដែលប្រមូលបានទាំងអស់ត្រូវបានរក្សាទុកតែនៅក្នុង RAM ហើយបរិមាណនៃអង្គចងចាំដែលប្រើប្រាស់ត្រូវបានគ្រប់គ្រងដោយចំនួនកំណត់ត្រាដែលបានរក្សាទុកចុងក្រោយ។

វាលសំណួរត្រូវបានបន្ថែម - សំណួរដូចគ្នាពីផ្នែកបន្ថែម pg_stat_statements (តម្រូវឱ្យដំឡើងជាមុន)។«

នេះ​ជា​ការ​ពិត​ណាស់ វា​នឹង​ជួយ​បាន​ច្រើន ប៉ុន្តែ​បញ្ហា​ដែល​ពិបាក​បំផុត​គឺ​ចំណុច​ទី​មួយ»។ព័ត៌មានដែលប្រមូលបានទាំងអស់ត្រូវបានរក្សាទុកតែក្នុង RAM ប៉ុណ្ណោះ។ ”, i.e. មានផលប៉ះពាល់លើមូលដ្ឋានគោលដៅ។ លើសពីនេះទៀតមិនមានប្រវត្តិចាក់សោនិងស្ថិតិតារាងទេ។ ទាំងនោះ។ ដំណោះស្រាយជាទូទៅនិយាយមិនពេញលេញ៖ "មិនទាន់មានកញ្ចប់ដែលត្រៀមរួចជាស្រេចសម្រាប់ការដំឡើងនៅឡើយទេ។ វាត្រូវបានស្នើឱ្យទាញយកប្រភព និងប្រមូលផ្តុំបណ្ណាល័យដោយខ្លួនឯង។ ដំបូងអ្នកត្រូវដំឡើងកញ្ចប់ "devel" សម្រាប់ម៉ាស៊ីនមេរបស់អ្នក ហើយកំណត់ផ្លូវទៅ pg_config នៅក្នុងអថេរ PATH ។"។

ជាទូទៅមានភាពច្របូកច្របល់ច្រើន ហើយក្នុងករណីមូលដ្ឋានទិន្នន័យផលិតកម្មធ្ងន់ធ្ងរ វាប្រហែលជាមិនអាចធ្វើអ្វីជាមួយម៉ាស៊ីនមេបានទេ។ យើង​ត្រូវ​បង្កើត​អ្វី​មួយ​ជា​របស់​ខ្លួន​យើង​ម្ដង​ទៀត។

ព្រមាន

ដោយសារបរិមាណច្រើន និងដោយសាររយៈពេលសាកល្បងមិនពេញលេញ អត្ថបទគឺមានលក្ខណៈជាព័ត៌មានជាចម្បង ជាជាងជាសំណុំនៃអត្ថបទ និងលទ្ធផលកម្រិតមធ្យម។
សម្ភារៈលម្អិតបន្ថែមទៀតនឹងត្រូវបានរៀបចំនៅពេលក្រោយនៅក្នុងផ្នែក

សេចក្តីព្រាងតម្រូវការសម្រាប់ដំណោះស្រាយ

វាចាំបាច់ក្នុងការបង្កើតឧបករណ៍ដែលអនុញ្ញាតឱ្យអ្នករក្សាទុក:

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. បំពេញប្រវត្តិបច្ចុប្បន្ន

ដើម្បីប្រមូលរូបភាពមើលដោយផ្ទាល់ ស្គ្រីប bash ត្រូវបានប្រើដែលដំណើរការមុខងារ plpgsql ។

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 0

plpgsql មុខងារ 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;

ដើម្បីប្រមូលរូបភាពមើល សេវាប្រព័ន្ធ និងស្គ្រីបពីរត្រូវបានប្រើ៖

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.target

pg_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.timer
# chmod 755 pg_current_activity.service

យើងចាប់ផ្តើមសេវាកម្ម៖
# systemctl daemon-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;

ជាការពិតណាស់ ពីពេលមួយទៅពេលមួយ ផ្នែកចាស់ត្រូវបានលុបដោយមិនចាំបាច់។

របាយការណ៍មូលដ្ឋាន

តាមពិតទៅ ហេតុអ្វីបានជាអ្វីៗទាំងអស់នេះត្រូវបានធ្វើ? ដើម្បីទទួលបានរបាយការណ៍ដែលនឹកឃើញយ៉ាងច្បាស់អំពី AWR របស់ Oracle ។

វាជាការសំខាន់ក្នុងការបន្ថែមថាដើម្បីទទួលបានរបាយការណ៍ អ្នកត្រូវបង្កើតការតភ្ជាប់រវាងទិដ្ឋភាព pg_stat_activity និង pg_stat_statements ។ តារាងត្រូវបានភ្ជាប់ដោយបន្ថែមជួរឈរ 'queryid' ទៅតារាង 'history_pg_stat_activity', 'archive_pg_stat_activity' ។ វិធីសាស្រ្តនៃការបន្ថែមតម្លៃជួរឈរគឺហួសពីវិសាលភាពនៃអត្ថបទនេះហើយត្រូវបានពិពណ៌នានៅទីនេះ − pg_stat_statements + pg_stat_activity + loq_query = pg_ash? .

ម៉ោង 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| ទំនាក់ទំនង | របៀប| ប្រភេទចាក់សោ ----------+----------+-----+---------- +--------- ----------+-----------+------ -------------+----- -------------- | ១| ២៦២២៤| 1-26224-2019 09:02:19| 32:16:00| {01}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ២| ២៦៣៩០| 45-26211-16541 2:26390:2019| 09:02:19| {34}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៣| ២៦៣៩១| 03-00-00 53:26211:16541| 3:26391:2019| {09}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៤| 02| 19-34-03 00:00:53| 26211:16541:4| {26531}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៥| ២៧២៨៤| 2019-09-02 19:35:27| 00:00:12| {26211}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៦| ២៧២៨៣| 16541-5-27284 2019:09:02| 19:44:02| {00}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៧| ២៧២៨៦| 00-19-27276 16541:6:27283| 2019:09:02| {19}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៨| ២៧៤២៣| 44-02-00 00:19:27276| 16541:7:27286| {2019}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ៩| ២៧៦៤៨| 09-02-19 44:02:00| 00:19:27276| {16541}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ១០| ២៧៦៥០| 8-27423-2019 09:02:19| 45:24:00| {00}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ១១| ២៧៧៣៥| 12-27394-16541 9:27648:2019| 09:02:19| {48}| ១៦៥៤១| AccessExclusiveLock| ទំនាក់ទំនង | ១២| ២៨៣៨០| 06-00-00 20:27647:16541| 10:27650:2019| {09}| ១៦៥៤១| AccessShareLock| ទំនាក់ទំនង | ១៣| ២៨៣៧៩| 02-19-48 06:00:00| 20:27647:16541| ២៨៣៧៧| ១៦៥៤១| AccessExclusiveLock| ទំនាក់ទំនង | | | | | ២៨៣៧៦| | 

ការទប់ស្កាត់ដំណើរការប្រវត្តិសាស្ត្រ

សំណើ៖

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| ឈ្មោះប្រើប្រាស់ | ឈ្មោះកម្មវិធី | ឈ្មោះទិន្នន័យ | បានចាប់ផ្តើម| រយៈពេល | រដ្ឋ | សំណួរ +----------+----------+----------+-----+ --------- ------------------------+---------------------+------ --------------------------+-------------------------------- ----------------- | ១| 1| តាសឺរ| psql| tdb26211| 1-2019-09 02:19:31| 54:00:00| ទំនេរ| | ២| 04| តាសឺរ| psql| tdb2| 26211-1-2019 09:02:19| 31:58:00| ទំនេរក្នុងប្រតិបត្តិការ| ចាប់ផ្តើម; | ៣| 00| តាសឺរ| psql| tdb06| 3-26211-1 2019:09:02| 19:32:16| ទំនេរក្នុងប្រតិបត្តិការ| ចាក់សោតារាង wafer_data; | ៤| 00| តាសឺរ| psql| tdb01| 45-4-26211 1:2019:09| 02:19:35| ទំនេរ| ប្តេជ្ញាចិត្ត; | ៥| 54| តាសឺរ| psql| tdb00| 01-23-5 26211:1:2019| 09:02:19| ទំនេរក្នុងប្រតិបត្តិការ| ចាប់ផ្តើម; | ៦| 38| តាសឺរ| psql| tdb46| 00-00-02 6:26211:1| 2019:09:02| ទំនេរក្នុងប្រតិបត្តិការ| ចាក់សោតារាង wafer_data; | ៧| 19| តាសឺរ| psql| tdb38| 54-00-00 08:7:26211| 1:2019:09| ទំនេរ| ប្តេជ្ញាចិត្ត; | ៨| 02| តាសឺរ| psql| tdb19| 39-08-00 42:42:8| 26211:1:2019| សកម្ម | ជ្រើសរើស test_del();

ការអភិវឌ្ឍន៍។

សំណួរជាមូលដ្ឋានដែលបានបង្ហាញ និងរបាយការណ៍លទ្ធផលបានធ្វើឱ្យជីវិតកាន់តែងាយស្រួលនៅពេលវិភាគឧប្បត្តិហេតុនៃការអនុវត្ត។
ដោយផ្អែកលើសំណួរជាមូលដ្ឋាន អ្នកអាចទទួលបានរបាយការណ៍ដែលស្រដៀងនឹង AWR របស់ Oracle ។
ឧទាហរណ៍របាយការណ៍សង្ខេប

+------------------------------------------------ ----------------------------------- | របាយការណ៍រួមសម្រាប់សកម្មភាព និងការរង់ចាំ។ 

នៅ​មាន​ជា​បន្ត​ទៀត។ បន្ទាប់នៅក្នុងជួរគឺការបង្កើតប្រវត្តិចាក់សោ (pg_stat_locks) ដែលជាការពិពណ៌នាលម្អិតបន្ថែមទៀតអំពីដំណើរការនៃការបំពេញតារាង។

ប្រភព: www.habr.com