pl/python调用aerospike

标签：

1.先安装pl/python模块

yum install postgresql94-plpython.x86_64 
在postgres用户下执行createlang plpythonu

2.编写python代码 /usr/lib64/python2.6/plpy_as_cli_test.py

import aerospike
import sys

config = {
  ‘hosts‘: [
      ( ‘192.168.0.30‘, 4000 )
  ],
  ‘policies‘: {
      ‘timeout‘: 1000 # milliseconds
  }
}

def get_as_data():
    global client
    if client == None:
        client = aerospike.client(config)
        client.connect()
    # Retrieve the record using the key.
    (key, meta, bins) = client.get((‘test‘,‘demo‘,‘foo‘))

3.编写pl/python存储过程

CREATE FUNCTION py_get_as_data()
  RETURNS void
AS $$
  import plpy_as_cli_test
  plpy_as_cli_test.get_as_data()
$$ LANGUAGE plpythonu;

4.在psql中执行如下命令

select py_get_as_data()

这样就完成了sql调用python代码完成aerospike交互的过程。

是不是很爽，sql可以通过pl/python中可以干任意想干的事情哦。

pl/python调用aerospike

标签：

原文地址：http://my.oschina.net/u/2427685/blog/490110