リアルタイム機械学習ノードリファレンス（アルファ）

ノードは、グラフが形成される基本単位です。 各ノードは特定のタスクを実行し、リンクを使用して連結し、ML パイプラインを表すグラフを形成できます。 ノードが実行するタスクは、データやスキーマの変換、機械学習の推論などの入力データに対する操作を表す。 ノードは、変換または推論された値を次のノードに出力します。

次のガイドでは、リアルタイム機械学習でサポートされるノードライブラリの概要を説明します。

ML パイプラインで使用するノードの検出

次のコードを Python ノートブックにコピーして、使用可能なすべてのノードを表示します。

from pprint import pprint
 
from rtml_nodelibs.core.nodefactory import NodeFactory as nf

# Discover Nodes
pprint(nf.discover_nodes())

応答の例

{'FieldOps': 'rtml_nodelibs.nodes.standard.preprocessing.fieldops.FieldOps',
 'FieldTrans': 'rtml_nodelibs.nodes.standard.preprocessing.fieldtrans.FieldTrans',
 'ModelUpload': 'rtml_nodelibs.nodes.standard.ml.artifact_utils.ModelUpload',
 'ONNXNode': 'rtml_nodelibs.nodes.standard.ml.onnx.ONNXNode',
 'Pandas': 'rtml_nodelibs.nodes.standard.preprocessing.pandasnode.Pandas',
 'Processor': 'rtml_nodelibs.nodes.standard.preprocessing.processor.Processor',
 'Receiver': 'rtml_nodelibs.nodes.standard.preprocessing.receiver.Receiver',
 'ScikitLearn': 'rtml_nodelibs.nodes.standard.ml.scikitlearn.ScikitLearn',
 'Simulator': 'rtml_nodelibs.nodes.standard.preprocessing.simulator.Simulator',
 'Split': 'rtml_nodelibs.nodes.standard.preprocessing.splitter.Split'}

標準ノード

標準ノードは、Pandas や ScikitLearn などのオープンソースデータサイエンスライブラリを基に構築されます。

ModelUpload

ModelUpload ノードは、 model_path を取得し、ローカルモデルパスからリアルタイム機械学習 BLOB ストアにモデルをアップロードする内部Adobeノードです。

model = ModelUpload(params={'model_path': model_path})
  
msg_model = model.process(None, 1)
  
model_id = msg_model.model['model_id']

ONXNode

ONXNode は、モデル ID を取得して、事前にトレーニングされた ONNX モデルを取り込み、それを使用して受信データに対するスコアを付ける内部Adobeノードです。

node_model_score = ONNXNode(params={"features": ['browser', 'device', 'login_page', 'product_page', 'search_page'], "model_id": model_id})

パンダス

次の Pandas ノードを使用して、任意の pd.DataFrame メソッドまたは一般的な pandas の最上位機能をインポートできます。 Pandas メソッドの詳細については、Pandas メソッドのドキュメント を参照してください。 トップレベルの関数について詳しくは、 一般的な関数の Pandas API リファレンスガイド を参照してください。

以下のノードは、"import": "map" を使用して、メソッド名をパラメーターに文字列として読み込み、その後、パラメーターをマップ関数として入力します。 以下の例では、{"arg": {"Desktop": 1, "Mobile": 0}, "na_action": 0} を使用してこれを行います。 マップを配置した後、inplace を True または False に設定するオプションがあります。 変換をインプレースで適用するかどうかに基づいて、 inplace を True または False に設定します。 デフォルトでは、"inplace": False は新しい列を作成します。 新しい列名の提供のサポートは、今後のリリースで追加される予定です。 最後の行 cols は、1 つの列名または列のリストにすることができます。 変換を適用する列を指定します。 この例では、device が指定されています。

#  df["device"] = df["device"].map({"Desktop":1, "Mobile":0}, na_action=0)
 
node_device_apply = Pandas(params={"import": "map",
    "kwargs": {"arg": {"Desktop": 1, "Mobile": 0}, "na_action": 0},
    "inplace": True,
    "cols": "device"})
 
 
# df["browser"] = df["browser"].map({"chrome": 1, "firefox": 0}, "na_action": 0})
 
node_browser_apply = Pandas(params={"import": "map",
    "kwargs": {"arg": {"chrome": 1, "firefox": 0}, "na_action": 0},
    "inplace": True,
    "cols": "browser"})

ScikitLearn

ScikitLearn ノードを使用すると、任意の ScikitLearn ML モデルまたはスケーラを読み込むことができます。 この例で使用されている値の詳細については、次の表を参照してください。

model_train = ScikitLearn(params={
    "features":['browser', 'device', 'login_page', 'product_page', 'search_page'],
    "label": "payment_confirm",
    "mode": "train",
    "model_path": "resources/model.onnx",
    "params": {
        "model": "sklearn.linear_model.LogisticRegression",
        "model_params": {"solver" : 'lbfgs'}
    }})
msg6 = model_train.process(msg5)

Split

次のノードを使用して、train_size または test_size を渡して、データフレームをトレーニングとテストに分割します。 これにより、複数インデックスを持つデータフレームが返されます。 msg5.data.xs(“train”) の例を使用して、トレーニングとテストのデータフレームにアクセスできます。

splitter = Split(params={"train_size": 0.7})
msg5 = splitter.process(msg4)

次の手順

次の手順では、リアルタイム機械学習モデルのスコアリングに使用するノードを作成します。 詳しくは、 リアルタイム機械学習ノートブックのユーザーガイド を参照してください。