Asynchronous queries
with PostgreSQL
P2D2 – Praha 2022
We are going to cover
▷




 

2
1.
Introducing
3
4
Gilles DAROLD
!"!#$
Author % !&'#(')*
MigOps Inc
##+##" 
▷
##%!&'#(
,#-..*."!#/#.,#-..*..
Contact :,#-..*#*.0.
Client Side

5
Client side
1 ## 
▷
23
▷

▷
#
6
Fork
"## 
▷
(14$5
▷
6 3)
▷
23# #
 
▷
!""$./!(7
▷
8%#
3
 9:3
/%#%
 0# *
7
Fork with transaction control
"## 
▷
(14$5
▷
6 3)
▷
23# #
/1/1/5$!5;%<
1#
▷
8%#
▷
!""$./!(7/1/16;%<
▷
!""$./!(7
3 %
#*
/%#%
 0# *
8
Queue Management System
"## 
▷
(14$5
▷
 3
▷
/.3=>
3
▷
13
▷
!""$./!(7
❏
3## '%3
❏
 
❏
 9:3
❏
53
9
Queue system with transaction
control
"## 
▷
(14$5
▷
 3
▷
/.3=>
##
 
8%%3
▷
13
▷
83
▷
!""$./!(7## 
▷
!""$./!(7
10
Queuing solutions
▷
#
▷

▷
/"
▷
7?')
#-
❏
13
❏
## 
❏

❏
2$2!3#
❏
 
❏
13% 
11
Libpq
▷
%## 
$
■

■
1
■
4
■

▷
"####
▷
 


#=:94@A>
12
Synchronous command processing
▷

8%#*
## #%*
B*
4
■
 #'4

13
Libpq, Synchronous example
14
9='C11D2/!"#C>E.D%#D.
%==>F94/1GH1G!7>
.D#)D.
.D'#D.
29I=>E
%=9JEK#=>ELL>M
%=N9JENK2ENLL>
#O=CP0@QC'=''N>>E
R
=>E
Asynchronous command processing
▷

 %*
▷
/
8%%#*
"# #*
4*
2%
■
H/"
▷
 /
#*
▷
8 #'%*
15
Libpq, Asynchronous example
16
9='C11D2/!"#C>E.D %# D.
%==>F94/1GH1G!7>
.D#)D.
.D'#D.
==9/=>>F95H>M
%==>994/1GH1G!7>M
29I=>E
%=9JEK#=>ELL>M
%=N9JENK2ENLL>
#O=CP0@QC'=''N>>E
R
R
R
Libpq, Asynchronous
/ 3 
#*
%% -
▷
$#
$%#%'*
▷
(
/3
17
Libpq, Asynchronous example
18
9='C11GG=>C>E
%==>F94/1GH1G!7>
.D#)D.
%=$#=>>.D%#D.
M
.D64/3SD.
8==(=>99@>
M
.D$3%#)D.
$#=>
R
.DD.
9/=>E
R
Libpq, Pipeline mode
$  ##
3'%*
▷
#"
 ##*
▷
''
*
▷

##' %%##*
▷
/*
▷
T+ #
##2/*
19
Libpq, Pipeline mode example
20
%=F#"=>>.D#)D.
.DID.
9='C$51/)/1H/5$54C>E
.D$3D.
%=2/=>99J>.D#)D.
.DD.
9='C$51/)/1H/5$54C>E
.DT%D.
%=##=>99J>.D#)D.
==9/=>F95H>.D%ID.
==9/=>F95H>.D%D.
#"=>E.D##D.
Libpq, Pipeline mode
4@A9:3
#-
▷
/
▷

▷
U
▷
)
21
Server Side
3
22
Server side
1 
▷
#G3
▷
3
▷
)
23
pg_background
▷
#G3G=>0:#
33
#3 =>
"- 
▷
#G3G=#>
63#%

5%*
▷
#G3G=#>
/%
3#*
24
pg_background / Synchronous call
25
9V/111W15$!5#G3E
/111W15$!5
.D13#%D.
9V11#G3G=#G3G=B11=D>2/!"#B>>=>E

00000000
@JX
.D1%#D.
9V11=D>%#E

0000000
@JX
pg_background / Asynchronous call
26
9V11#G3G=B11=D>2/!"#B>E
#G3G
0000000000000000000000
 YXX@Y
.D6D.
9V11=D>%#E

0000000
@JX
.D4D.
9V11D2/!"#G3G=YXX@Y>=>E

00000000
@JX
pg_background / No results
27
9V11#G3G=;11B>E
#G3G
0000000000000000000000
 YXXZ@
9V11D2/!"#G3G=YXXZ@>E
#G3G
0000000000000000000000
9V11D2/!"#G3G=YXXZ@>=>E
1//!/-$6YXXZ@,
▷
233
3
dblink
▷
1
.=#G*%>
 
/#
28
dblink / synchronous call
29
9V/111W15$!53E
/111W15$!5
9V11D2/!"3=B9B'B11=D>2/!"#B'>@=>E

00000
@JX
=@>
▷
3='['%GG\>0:%
dblink / asynchronous call
30
▷
3GG='>0:
1 
/@'J
▷
3GG=['%GG\>0:%
%
8#
▷
H3G='># 
dblink / asynchronous call
31
9V113G=;@<'B9B>E
3G
0000000000000000
!7
9V113GG=B@B'B11=D>2/!"G>E
3GG
0000000000000000000
 @
[***3)\
9V11D2/!"3GG=B@B>@=%@>E
%@
]0000000000000
@JJJJJJJJ
Scheduling
3
32
Schedulers
▷
#G
03%
▷
#G 
%
▷
#GGN
"N%N
1N
▷
#'#(3'***
▷
 %#3
▷
# 
%3
1##GGN
33
pg_cron
34
▷
#0N%
,#-..*..#G
,
(33.##
■
G#G9B#GB
 #
-
pg_cron, example
35
.D6Y-YJ=4">D.
11*=BYJYDD^B'
__61112/!"8`1/1G K=>0B@3B__>E

0000000000
A&
.D/% #D.
11*=B0B'BDDDDDB'BG#=>B>E

0000000000
AY
11*=B0B>E.D3D.
pg_timetable
36
▷
0N%
,#-..*.0#.#G 
#',4!
%%-
■
3'
■
1'0
■
6I 
■
#3
■
-
■
1
▷
53 *
pg_timetable, example
37
00/#*G%=>JJ-JQ-
11 *GN=B0%B'BQJDaDB'B11#*G%=>B>E
00/% #
11 *GN=
NG9:<0B'
NG9:BDDDDDB'
NG9:;G#=>B'
NG%G9:/H1>E
pg_dbms_job
38
▷
NN
,#-..*."!#/#.#GGN
#',

■
$ 
■
1'4#
■
6
■
-
pg_dbms_job
39
▷
NI -
'
% 
■
5H.H//15G$"1"% 
bN*
■
5H% 
▷
N'## #*
▷
UGG-
#%N*6%Q*
▷
UGG#-
"%N# *6%@JJJ*
pg_dbms_job, immediate execution
40
▷
U, 
▷
=2$2!>GN*GGN
▷
U%
11GN*=
00
 B(14$5
#@=>E
156EB
>$5!NE
pg_dbms_job, really immediate?
41
▷
UGG-
#%N*6%Q*
▷
` #F
GN*=>5!$2c#GGN
N*
$15@JJ#GGN*
#GGN3NI dNGGe
% I *
pg_dbms_job, delayed execution
42
▷
U, 
▷
%%# 
▷
1#%Nb'
&*
11GN*=
 B(14$5GG#=>E156EB'
G=BB'=>>LB@B--'.D D.
G=BB'=>>LB&B--.D&D.
>$5!NE
Thanks !
Email : gilles@darold.net
Any quesons?
43