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);
}