Simple PostgreSQL plpython function for message publication through Redis pub/sub

redispub_plpython

CREATE OR REPLACE FUNCTION redis_pubsub.notify(channel text, message text, host text, port integer)
  RETURNS void AS
$BODY$
#Safeguard against null or empty values
if (channel is None) or (message is None):
    return
if (host is None) or (host.strip() == ""):
    redishost = "127.0.0.1"
else:
    redishost = host
if (port is None) or (port <= 0):
    redisport = 6379
else:
    redisport = port

import redis
#Get Redis connection
r = redis.StrictRedis(host=redishost, port=redisport, db=0)
#Publish message
r.publish(channel, message)
$BODY$
  LANGUAGE plpython3u VOLATILE;