PLPython Fenced模式

在fenced模式中添加plpython非安全语言。在数据库编译时需要将python集成进数据库中，在configure阶段加入–with-python选项。同时也可指定安装plpython的python路径，添加选项–with-includes=’/python-dir=path’。

在启动数据库之前配置GUC参数unix_socket_directory ，指定unix_socket进程间通讯的文件地址。用户需要提前在user-set-dir-path下创建文件夹，并将文件夹权限修改为可读可写可执行状态。

  1. unix_socket_directory = '/user-set-dir-path'

配置完成，启动数据库。

将plpython加入数据库编译，并设置好GUC参数unix_socket_directory后，在启动数据库的过程中，自动创建fenced-Master进程。在数据库不进行python编译的情况下，fenced模式需要手动拉起master进程，在GUC参数设置完成后，输入创建master进程命令。

启动fenced-Master进程，命令为：

  1. gaussdb --fenced -k /user-set-dir-path -D /user-set-dir-path &

完成fence模式配置，针对plpython-fenced UDF数据库将在fenced-worker进程中执行UDF计算。

使用指导

  • 创建Extension

    • 当编译的plpython为python2时：

      1. openGauss=# create Extension plpythonu;
      2. CREATE Extension

    • 当编译的plpython为python3时：

      1. openGauss=# create Extension plpython3u;
      2. CREATE Extension

    下面示例是以python2为例。

  • 创建plpython-fenced UDF

    1. openGauss=# create or replace function pymax(a int, b int)
    2. openGauss-# returns INT
    3. openGauss-# language plpythonu fenced
    4. openGauss-# as $$
    5. openGauss$# import numpy
    6. openGauss$# if a > b:
    7. openGauss$#     return a;
    8. openGauss$# else:
    9. openGauss$#     return b;
    10. openGauss$# $$;
    11. CREATE FUNCTION

  • 查看UDF信息

    1. openGauss=# select * from pg_proc where proname='pymax';
    2. -[ RECORD 1 ]----+--------------
    3. proname          | pymax
    4. pronamespace     | 2200
    5. proowner         | 10
    6. prolang          | 16388
    7. procost          | 100
    8. prorows          | 0
    9. provariadic      | 0
    10. protransform     | -
    11. proisagg         | f
    12. proiswindow      | f
    13. prosecdef        | f
    14. proleakproof     | f
    15. proisstrict      | f
    16. proretset        | f
    17. provolatile      | v
    18. pronargs         | 2
    19. pronargdefaults  | 0
    20. prorettype       | 23
    21. proargtypes      | 23 23
    22. proallargtypes   |
    23. proargmodes      |
    24. proargnames      | {a,b}
    25. proargdefaults   |
    26. prosrc           |
    27.                  | import numpy
    28.                  | if a > b:
    29.                  |     return a;
    30.                  | else:
    31.                  |     return b;
    32.                  |
    33. probin           |
    34. proconfig        |
    35. proacl           |
    36. prodefaultargpos |
    37. fencedmode       | t
    38. proshippable     | f
    39. propackage       | f
    40. prokind          | f
    41. proargsrc        |

  • 运行UDF

    • 创建一个数据表：

      1. openGauss=# create table temp (a int ,b int) ;
      2. CREATE TABLE
      3. openGauss=# insert into temp values (1,2),(2,3),(3,4),(4,5),(5,6);
      4. INSERT 0 5

    • 运行UDF：

      1. openGauss=# select pymax(a,b) from temp;
      2.  pymax
      3. -------
      4.      2
      5.      3
      6.      4
      7.      5
      8.      6
      9. (5 rows)