Function RedisLog

plugins/python/redisgears_python.c:3135–3176

}

static PyObject* RedisLog(PyObject *cls, PyObject *args, PyObject *kargs){
    PyObject* logLevel = GearsPyDict_GetItemString(kargs, "level");
    PyObject* logMsg = NULL;
    if(PyTuple_Size(args) < 1 || PyTuple_Size(args) > 2){
        PyErr_SetString(GearsError, "log function must get a log message as input");
        return NULL;
    }
    if(PyTuple_Size(args) == 2){
        RedisModule_Log(staticCtx, "warning", "Specify log level as the first argument to log function is depricated, use key argument 'level' instead");
        logLevel = PyTuple_GetItem(args, 0);
        logMsg = PyTuple_GetItem(args, 1);
    }else{
        logMsg = PyTuple_GetItem(args, 0);
    }

    if(!PyUnicode_Check(logMsg)){
        PyErr_SetString(GearsError, "Log message must be a string");
        return NULL;
    }

    const char* logMsgCStr = PyUnicode_AsUTF8AndSize(logMsg, NULL);
    const char* logLevelCStr = "notice";

    if(logLevel){
        if(!PyUnicode_Check(logLevel)){
            PyErr_SetString(GearsError, "Log level must be a sting (debug/verbose/notice/warning)");
            return NULL;
        }
        logLevelCStr = PyUnicode_AsUTF8AndSize(logLevel, NULL);
        if(strcmp(logLevelCStr, "debug") != 0 &&
                strcmp(logLevelCStr, "verbose") != 0 &&
                strcmp(logLevelCStr, "notice") != 0 &&
                strcmp(logLevelCStr, "warning") != 0){
            PyErr_SetString(GearsError, "Log level should be one of the following : debug,verbose,notice,warning");
            return NULL;
        }
    }

    RedisModule_Log(staticCtx, logLevelCStr, "GEARS: %s", logMsgCStr);
    Py_INCREF(Py_None);
    return Py_None;
}

static RedisModuleString** createArgs(PyObject *args){
    // Declare and initialize variables for arguments processing.