redis

Through DolphinDB's redis plugin, users can establish a connection to a redis server at a specified IP and port, and perform data operations. The redis plugin uses the Hiredis library, a lightweight Redis C client library.

Installation (with installPlugin)

Required server version: DolphinDB 2.00.10 or higher.

Supported OS: windows x64 and Linux x64.

Installation Steps:

(1) Use listRemotePlugins to check plugin information in the plugin repository.

Note: For plugins not included in the provided list, you can install through precompiled binaries or compile from source. These files can be accessed from our GitHub repository by switching to the appropriate version branch.

login("admin", "123456")
listRemotePlugins(, "http://plugins.dolphindb.com/plugins/")

(2) Invoke installPlugin for plugin installation.

installPlugin("redis")

(3) Use loadPlugin to load the plugin before using the plugin methods.

loadPlugin("redis")

Method References

connect

Syntax

connect(host, port)

Details

The method establishes a connection to the redis server and returns a handle for the redis connection.

Parameters

  • host: A STRING scalar indicating the IP address of the redis server.
  • port: An INT scalar indicating the port number of the redis server.

Examples

Assuming the redis server is listening on 127.0.0.1:6379.

conn = redis::connect("127.0.0.1",6379)

run

Syntax

run(conn, arg1, arg2, arg3, ...)

Details

The method executes redis commands. If the redis is password-protected, use run(conn, "AUTH", "password") to gain access. The results of the redis commands will be returned in DolphinDB type with automatic conversion.

Note: If an error occurs during execution, the connection cannot be used anymore. Release this connection and reconnect.

Parameters

  • conn: The redis connection handle obtained through connect.
  • arg1: A STRING scalar indicating redis commands such as SET, GET, etc.
  • arg2, arg3, ...: Parameters required by the redis command.

Examples

In the following example, the run method is first used to execute the SET command, setting “abc“ to hold the string “vabc“. Then, the GET command is executed to get the value of “abc“.

conn = redis::connect("127.0.0.1",6379)
redis::run(conn, "SET", "abc", "vabc")
val = redis::run(conn, "GET", "abc")
val == "vabc"

batchSet

Syntax

batchSet(conn, keys, values)

Details

The method sets the given keys to their respective values. It can be used with the subscribeTable function to facilitate the bulk data insertion into a redis database.

Note: If an error occurs during execution, the connection cannot be used anymore. Release this connection and reconnect.

Parameters

  • conn: The Redis connection handle obtained through connect.
  • keys: A STRING scalar or vector indicating the keys to set.
  • values: A STRING scalar or vector indicating the values to set.

Examples

conn = redis::connect("127.0.0.1",6379)

redis::batchSet(conn, "k1", "v1")

keys = ["k2", "k3", "k4"]
values = ["v2", "v3", "v4"]
redis::batchSet(conn, keys, values)

batchHashSet

Syntax

batchHashSet(conn, ids, fieldData)

Details

The method sets the specified fields to their respective values into redis hashes. It is used to batch write data to the redis database.

Note: If an error occurs during execution, the connection cannot be used anymore. Release this connection and reconnect.

Parameters

  • conn: Redis connection handle obtained through connect.
  • ids: A STRING array, where each element serves as a key of the Redis hash. These keys correspond to specific rows of data in the fieldData table.
  • fieldData: A table where each column is of STRING type. Each column name corresponds to a field of the hash, and the value serves as the value of the Redis hash.

Examples

loadPlugin("path/PluginRedis.txt");
go

// Generate data
n=43200
instrument_id = take("HO2305-D-",n)+string(1..n)
time_stamp = timestamp(2024.02.02T09:30:01..2024.02.02T21:30:00)
exchange = take("CFFEX",n)
last_price = rand(10.0,n)
volume = rand(100000,n)
bid_price1 = rand(10.0,n)
bid_volume1 = rand(1000,n)
bid_price2 = rand(10.0,n)
bid_volume2 = rand(1000,n)
bid_price3 = rand(10.0,n)
bid_volume3 = rand(1000,n)
bid_price4 = rand(10.0,n)
bid_volume4 = rand(1000,n)
bid_price5 = rand(10.0,n)
bid_volume5 = rand(1000,n)
t = table(instrument_id, time_stamp,exchange, last_price,volume, bid_price1,bid_volume1, bid_price2,bid_volume2,bid_price3,bid_volume3,bid_price4,bid_volume4,bid_price5,bid_volume5)
conn=redis::connect("127.0.0.1",6379)

// Batch set operation
ids = exec instrument_id from t
fieldData =  select string(time_stamp) as time_stamp,string(exchange) as exchange,string(last_price) as last_price,string(volume) as volume,string(bid_price1) as bid_price1,string(bid_volume1) as bid_volume1,string(bid_price2) as bid_price2,string(bid_volume2) as bid_volume2,string(bid_price3) as bid_price3,string(bid_volume3) as bid_volume3,string(bid_price4) as bid_price4,string(bid_volume4) as bid_volume4,string(bid_price5) as bid_price5,string(bid_volume5) as bid_volume5 from t

redis::batchHashSet(conn, ids, fieldData)

release

Syntax

release(conn)

Details

The method closes the specified connection to the redis server.

Parameters

  • conn: Redis connection handle obtained through connect.

Examples

conn = redis::connect("127.0.0.1",6379)
redis::release(conn)

releaseAll

Syntax

releaseAll()

Details

The method closes all connections to the redis server.

Examples

conn = redis::releaseAll()

getHandle

Syntax

getHandle(token)

Details

The method returns a specific redis handle.

Parameters

  • token: A unique identifier for a Redis connection, obtained from the first column of the table returned by getHandleStatus.

Examples

handle = redis::getHandle(token)

getHandleStatus

Syntax

getHandleStatus()

Details

The method is used to get information about all established connections. It returns a table with the following columns:

  • token: The unique identifier for the connection, used to obtain the handle through getHandle(token).
  • address: The "ip:port" network of the connected Redis server.
  • createdTime: The time when the connection is created.

Examples

status = redis::getHandleStatus()

Usage Examples

Here's an example of writing data subscribed by subscribeTable to the redis database:

loadPlugin("path/PluginRedis.txt");
go

dropStreamTable(`table1)

colName=["key", "value"]
colType=["string", "string"]
enableTableShareAndPersistence(table=streamTable(100:0, colName, colType), tableName=`table1, cacheSize=10000, asynWrite=false)

def myHandle(conn, msg) {
	redis::batchSet(conn, msg[0], msg[1])
}

conn = redis::connect("replace_with_redis_server_ip",6379)
subscribeTable(tableName="table1", handler=myHandle{conn})

n = 1000000
for(x in 0:n){
	insert into table1 values("key" + x, "value" + x)
}

t = table(n:0, [`id, `val], [`string, `string])
for(x in 0:n){
	insert into t values("key" + x, redis::run(conn, "GET", "key" + x))
}

ret = exec count(*) from t

assert "test", n==ret