Manage UDFs

The following code example shows how to create, register, and execute a user-defined function (UDF) with the PHP client.

<?php

namespace Aerospike;

$namespace = "test";
$set = "test";
$socket = "/tmp/asld_grpc.sock";

$client = Client::connect($socket);
echo "* Connected to the local daemon: $client->socket \n";

// Create the UDF
$udfBody = 'function testFunc1(rec, div)
    local ret = map();                     -- Initialize the return value (a map)

    local x = rec["bin1"];                 -- Get the value from record bin named "bin1"

    rec["bin2"] = math.floor(x / div);     -- Set the value in record bin named "bin2"

    aerospike:update(rec);                 -- Update the main record

    ret["status"] = "OK";                   -- Populate the return status
    return ret;                             -- Return the Return value and/or status
end';

$wp = new WritePolicy();

// Register the UDF
$client->registerUdf($wp, $udfBody, "udf1.lua", UdfLanguage::lua());

$ns = "test";
$set = "udf-set";
$key = new Key($ns, $set, "key1");

$bin1 = new Bin("bin1", 20);
$bin2 = new Bin("bin2", 1);
$client->put($wp, $key, [$bin1, $bin2]);

// Execute the UDF
$res = $client->udfExecute($wp, $key, "udf1", "testFunc1", [2]);
echo "\n Execute UDF result: ";
var_dump($res);

usleep(300000);

echo "\n Get record result: ";
$rp = new ReadPolicy();
$rec = $client->get($rp, $key);
var_dump($rec->bins);

// List all UDFs
$listUdf = $client->listUdf($rp);
echo "\n Count of UDFs: ",count($listUdf);
var_dump($listUdf);