473      阿里云

在线算法开发手册__算法规范_开发者指南_推荐引擎-阿里云

先决条件

您需要熟悉基于NodeJS的开发模式，主要包括JS的基本语法+异步编程+函数回调（后两项为高级进阶要求，依您所需要开发的算法复杂度选择具备即可）。

在线自定义算法代码可在推荐引擎提供的界面中进行编辑修改，并运行在推荐引擎内置的NodeJS环境中，您不需要在本地搭建NodeJS的环境。

推荐引擎提供了适用于个性化推荐的多种算法和模板，了解详情请访问系统内置算法和模板说明

基本知识

在线流程中，您要编写的算法体现为流程图中的一个个节点，如https://dtboost.aliyun.com/re/onlineflow?tp=tpl&id=45 所示：其中节点表现为函数，函数体基本结构如下

0   // 下面这部分是流程节点运行时真正的执行代码，要求您提交的在线代码严格按照以下格式。为方便讲解起见，我们给他起个代号叫做MAIN_ENTRY
1   function() {
2     // 函数体内您可以定义一些公用的变量或函数
3     var test_variable = 0;
4     var test_function = function() {
5       console.log('i am test_function');
6     }
7     var callback = this; // NodeJS里的回调函数习惯用callback表示，这里直接赋值，符合程序员习惯
8     var reclist = arguments[0][0]; //arguments[0][0]表示上游节点的输出数据，典型的情况下就是一个推荐列表
9     ... // 在这里完成您的处理逻辑
10    return callback(null, reclist); // 值得注意的是，这里必须写成callback的形式（由于是最后一个语句，因此有没有return无区别，但对于需要提前回调的情况，请注意使用return callback），而不能直接return一个变量，否则下游节点获取不到本节点的输出，程序也会hang住，框架会一直等待该函数回调事件
11  }

注意事项

1. 第2-6行，定义的内层公用变量和函数，您可以在MAIN_ENTRY中调用，后文会提及公用变量和方法的一种高级用法（请移步“高级用法-使用共享缓存”）。
2. 第8行，arguments代表的是上游输出给下游节点的数据列表，是一个二维数组，但由于流程中限制了每个节点只能有一个直接上游，因此arguments的第一维长度也就固定为<=1（=0对应的情况是callback的时候无第二个参数）。第二维的长度由上游节点callback时的参数长度决定，假设上游callback(null, ‘a’, ‘b’)，那么arguments[0] = [‘a’,’b’]
3. 第10行，关于callback函数的第一个参数，在“NodeJS最佳实践”中，callback的第一个参数固定表示是否遇到错误，如果callback的第一个参数不为null，框架会认为程序遇到异常退出，后续流程不会再继续流程。我们在这里编写代码的时候，也请遵循这一实践规范。
4. 第10行，return callback(null, reclist)，这里的reclist就是本节点输出给下游节点的数据，对应注释第2）条，下游可以通过arguments[0][0]获取。
5. 代码中如何获取算法启动参数？对于同一算法，在线SDK允许您定义不同的函数参数取值，以完成不同的操作，这部分请参见https://dtboost.aliyun.com/re#/alg/editAlg?id=29, 这个算法里定义了一个topn参数，您可以在MAIN_ENTRY中通过topn = parseInt(topn);获取。需要注意的是，所有算法启动参数均以string类型传入，由您自己决定是否需要进行类型转换。

初级用法

下面展示了一个对推荐列表按item_id进行去重的简单方法

function() {
  var callback = this;
  var reclist = arguments[0][0];
  var occupy = {}, mergedList = [];
  reclist.forEach(function(item) {
    var item_id = item.item_id === undefined ? item[0] : item.item_id;
    if (typeof(occupy[item_id]) === 'undefined') {
      occupy[item_id] = 1;
      mergedList.push(item);
    }
  });
  return callback(null, mergedList);
}

这个代码很简单，这里不做进一步的详细分析。

function() { // 函数A
  this.cache_A = 'cache_A ';
  ...
}

function() { // 函数B
  console.log(tihs.cache_A); // 将输出cache_A 
  ...
}

function() { // 我们假设这个函数的名称叫setup
  var add = function(a,b) { return a+b; }
  var sub = function(a,b) { return a-b; }
  var callback = this;
  this.func_add = add;
  this.func_sub = sub;
  var c = this.func_add(1,2); // c=3
  return callback(null, c);
}