Merge pull request #1707 from Azure/release_update/Release-124

update samples from Release-124 as a part of  SDK release

configuration.ipynb

@@ -103,7 +103,7 @@
       "source": [
         "import azureml.core\n",
         "\n",
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

contrib/RAPIDS/azure-ml-with-nvidia-rapids.ipynb

@@ -188,13 +188,6 @@
         "### Script to process data and train model"
       ]
     },
-    {
-      "cell_type": "markdown",
-      "metadata": {},
-      "source": [
-        "The _process_data.py_ script used in the step below is a slightly modified implementation of [RAPIDS Mortgage E2E example](https://github.com/rapidsai/notebooks-contrib/blob/master/intermediate_notebooks/E2E/mortgage/mortgage_e2e.ipynb)."
-      ]
-    },
     {
       "cell_type": "code",
       "execution_count": null,
@@ -373,7 +366,7 @@
         "run_config.target = gpu_cluster_name\n",
         "run_config.environment.docker.enabled = True\n",
         "run_config.environment.docker.gpu_support = True\n",
-        "run_config.environment.docker.base_image = \"mcr.microsoft.com/azureml/base-gpu:intelmpi2018.3-cuda10.0-cudnn7-ubuntu16.04\"\n",
+        "run_config.environment.docker.base_image = \"mcr.microsoft.com/azureml/openmpi4.1.0-cuda11.1-cudnn8-ubuntu20.04\"\n",
         "run_config.environment.spark.precache_packages = False\n",
         "run_config.data_references={'data':data_ref.to_config()}"
       ]

contrib/fairness/fairlearn-azureml-mitigation.ipynb

@@ -49,7 +49,7 @@
         "* `fairlearn>=0.6.2` (pre-v0.5.0 will work with minor modifications)\n",
         "* `joblib`\n",
         "* `liac-arff`\n",
-        "* `raiwidgets~=0.7.0`\n",
+        "* `raiwidgets`\n",
         "\n",
         "Fairlearn relies on features introduced in v0.22.1 of `scikit-learn`. If you have an older version already installed, please uncomment and run the following cell:"
       ]

contrib/fairness/fairlearn-azureml-mitigation.yml

@@ -6,4 +6,4 @@ dependencies:
   - fairlearn>=0.6.2
   - joblib
   - liac-arff
-  - raiwidgets~=0.13.0
+  - raiwidgets~=0.17.0

contrib/fairness/upload-fairness-dashboard.ipynb

@@ -51,7 +51,7 @@
         "* `fairlearn>=0.6.2` (also works for pre-v0.5.0 with slight modifications)\n",
         "* `joblib`\n",
         "* `liac-arff`\n",
-        "* `raiwidgets~=0.7.0`\n",
+        "* `raiwidgets`\n",
         "\n",
         "Fairlearn relies on features introduced in v0.22.1 of `scikit-learn`. If you have an older version already installed, please uncomment and run the following cell:"
       ]

contrib/fairness/upload-fairness-dashboard.yml

@@ -6,4 +6,4 @@ dependencies:
   - fairlearn>=0.6.2
   - joblib
   - liac-arff
-  - raiwidgets~=0.13.0
+  - raiwidgets~=0.17.0

how-to-use-azureml/automated-machine-learning/automl_env.yml

@@ -1,30 +1,30 @@
 name: azure_automl
+channels:
+  - conda-forge
+  - pytorch
+  - main
 dependencies:
   # The python interpreter version.
-  # Currently Azure ML only supports 3.5.2 and later.
-- pip==21.1.2
-- python>=3.5.2,<3.8
-- nb_conda
-- boto3==1.15.18
-- matplotlib==2.1.0
-- numpy==1.18.5
-- cython
-- urllib3<1.24
-- scipy>=1.4.1,<=1.5.2
-- scikit-learn==0.22.1
-- pandas==0.25.1
-- py-xgboost<=0.90
-- conda-forge::fbprophet==0.5
-- holidays==0.9.11
+  # Currently Azure ML only supports 3.6.0 and later.
+- pip==20.2.4
+- python>=3.6,<3.9
+- matplotlib==3.3.4
+- py-xgboost==1.3.3
 - pytorch::pytorch=1.4.0
+- conda-forge::fbprophet==0.7.1
 - cudatoolkit=10.1.243
-- tornado==6.1.0
+- tqdm==4.62.3
+- notebook
+- pywin32==225
+- PySocks==1.7.1
+- conda-forge::pyqt==5.12.3
 
 - pip:
   # Required packages for AzureML execution, history, and data preparation.
-  - azureml-widgets~=1.36.0
+  - azureml-widgets~=1.39.0
   - pytorch-transformers==1.0.0
-  - spacy==2.1.8
+  - spacy==2.2.4
+  - pystan==2.19.1.1
   - https://aka.ms/automl-resources/packages/en_core_web_sm-2.1.0.tar.gz
-  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.36.0/validated_win32_requirements.txt [--no-deps]
+  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.39.0/validated_win32_requirements.txt [--no-deps]
   - arch==4.14

how-to-use-azureml/automated-machine-learning/automl_env_linux.yml

@@ -1,30 +1,33 @@
 name: azure_automl
+channels:
+  - conda-forge
+  - pytorch
+  - main
 dependencies:
   # The python interpreter version.
-  # Currently Azure ML only supports 3.5.2 and later.
-- pip==21.1.2
-- python>=3.5.2,<3.8
-- nb_conda
-- boto3==1.15.18
-- matplotlib==2.1.0
-- numpy==1.18.5
-- cython
-- urllib3<1.24
+  # Currently Azure ML only supports 3.6.0 and later.
+- pip==20.2.4
+- python>=3.6,<3.9
+- boto3==1.20.19
+- botocore<=1.23.19
+- matplotlib==3.3.4
+- numpy==1.19.5
+- cython==0.29.14
+- urllib3==1.26.7
 - scipy>=1.4.1,<=1.5.2
 - scikit-learn==0.22.1
-- pandas==0.25.1
-- py-xgboost<=0.90
-- conda-forge::fbprophet==0.5
-- holidays==0.9.11
+- py-xgboost<=1.3.3
+- holidays==0.10.3
+- conda-forge::fbprophet==0.7.1
 - pytorch::pytorch=1.4.0
 - cudatoolkit=10.1.243
-- tornado==6.1.0
 
 - pip:
   # Required packages for AzureML execution, history, and data preparation.
-  - azureml-widgets~=1.36.0
+  - azureml-widgets~=1.39.0
   - pytorch-transformers==1.0.0
-  - spacy==2.1.8
+  - spacy==2.2.4
+  - pystan==2.19.1.1
   - https://aka.ms/automl-resources/packages/en_core_web_sm-2.1.0.tar.gz
-  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.36.0/validated_linux_requirements.txt [--no-deps]
+  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.39.0/validated_linux_requirements.txt [--no-deps]
   - arch==4.14

how-to-use-azureml/automated-machine-learning/automl_env_mac.yml

@@ -1,31 +1,34 @@
 name: azure_automl
+channels:
+  - conda-forge
+  - pytorch
+  - main
 dependencies:
   # The python interpreter version.
-  # Currently Azure ML only supports 3.5.2 and later.
-- pip==21.1.2
+  # Currently Azure ML only supports 3.6.0 and later.
+- pip==20.2.4
 - nomkl
-- python>=3.5.2,<3.8
-- nb_conda
-- boto3==1.15.18
-- matplotlib==2.1.0
-- numpy==1.18.5
-- cython
-- urllib3<1.24
+- python>=3.6,<3.9
+- boto3==1.20.19
+- botocore<=1.23.19
+- matplotlib==3.3.4
+- numpy==1.19.5
+- cython==0.29.14
+- urllib3==1.26.7
 - scipy>=1.4.1,<=1.5.2
 - scikit-learn==0.22.1
-- pandas==0.25.1
-- py-xgboost<=0.90
-- conda-forge::fbprophet==0.5
-- holidays==0.9.11
+- py-xgboost<=1.3.3
+- holidays==0.10.3
+- conda-forge::fbprophet==0.7.1
 - pytorch::pytorch=1.4.0
 - cudatoolkit=9.0
-- tornado==6.1.0
 
 - pip:
   # Required packages for AzureML execution, history, and data preparation.
-  - azureml-widgets~=1.36.0
+  - azureml-widgets~=1.39.0
   - pytorch-transformers==1.0.0
-  - spacy==2.1.8
+  - spacy==2.2.4
+  - pystan==2.19.1.1
   - https://aka.ms/automl-resources/packages/en_core_web_sm-2.1.0.tar.gz
-  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.36.0/validated_darwin_requirements.txt [--no-deps]
+  - -r https://automlsdkdataresources.blob.core.windows.net/validated-requirements/1.39.0/validated_darwin_requirements.txt [--no-deps]
   - arch==4.14

how-to-use-azureml/automated-machine-learning/classification-bank-marketing-all-features/auto-ml-classification-bank-marketing-all-features.ipynb

@@ -77,6 +77,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
+        "import json\n",
         "import logging\n",
         "\n",
         "from matplotlib import pyplot as plt\n",
@@ -104,7 +105,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -153,7 +154,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Experiment Name'] = experiment.name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]
@@ -410,7 +411,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run_customized, fitted_model_customized = remote_run.get_output()"
+        "# Retrieve the best Run object\n",
+        "best_run = remote_run.get_best_child()"
       ]
     },
     {
@@ -419,7 +421,7 @@
       "source": [
         "## Transparency\n",
         "\n",
-        "View updated featurization summary"
+        "View featurization summary for the best model - to study how different features were transformed. This is stored as a JSON file in the outputs directory for the run."
       ]
     },
     {
@@ -428,36 +430,14 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "custom_featurizer = fitted_model_customized.named_steps['datatransformer']\n",
-        "df = custom_featurizer.get_featurization_summary()\n",
-        "pd.DataFrame(data=df)"
-      ]
-    },
-    {
-      "cell_type": "markdown",
-      "metadata": {},
-      "source": [
-        "Set `is_user_friendly=False` to get a more detailed summary for the transforms being applied."
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "df = custom_featurizer.get_featurization_summary(is_user_friendly=False)\n",
-        "pd.DataFrame(data=df)"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "df = custom_featurizer.get_stats_feature_type_summary()\n",
-        "pd.DataFrame(data=df)"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "\n",
+        "pd.DataFrame.from_records(records)"
       ]
     },
     {
@@ -499,7 +479,7 @@
         "model_explainability_run.wait_for_completion()\n",
         "\n",
         "# Get the best run object\n",
-        "best_run, fitted_model = remote_run.get_output()"
+        "best_run = remote_run.get_best_child()"
       ]
     },
     {
@@ -629,7 +609,16 @@
         "\n",
         "### Retrieve the Best Model\n",
         "\n",
-        "Below we select the best pipeline from our iterations.  The `get_output` method returns the best run and the fitted model. Overloads on `get_output` allow you to retrieve the best run and fitted model for *any* logged metric or for a particular *iteration*."
+        "Below we select the best pipeline from our iterations.  The `get_best_child` method returns the Run object for the best model based on the default primary metric. There are additional flags that can be passed to the method if we want to retrieve the best Run based on any of the other supported metrics, or if we are just interested in the best run among the ONNX compatible runs. As always, you can execute `remote_run.get_best_child??` in a new cell to view the source or docs for the function."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "remote_run.get_best_child??"
       ]
     },
     {
@@ -649,7 +638,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = remote_run.get_output()"
+        "best_run = remote_run.get_best_child()"
       ]
     },
     {

how-to-use-azureml/automated-machine-learning/classification-credit-card-fraud/auto-ml-classification-credit-card-fraud.ipynb

@@ -93,7 +93,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -116,7 +116,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Experiment Name'] = experiment.name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]

how-to-use-azureml/automated-machine-learning/classification-text-dnn/auto-ml-classification-text-dnn.ipynb

@@ -63,6 +63,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
+        "import json\n",
         "import logging\n",
         "import os\n",
         "import shutil\n",
@@ -96,7 +97,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -126,7 +127,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Experiment Name'] = experiment.name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]
@@ -340,8 +341,9 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "You can test the model locally to get a feel of the input/output. When the model contains BERT, this step will require pytorch and pytorch-transformers installed in your local environment. The exact versions of these packages can be found in the **automl_env.yml** file located in the local copy of your MachineLearningNotebooks folder here:\n",
-        "MachineLearningNotebooks/how-to-use-azureml/automated-machine-learning/automl_env.yml"
+        "For local inferencing, you can load the model locally via. the method `remote_run.get_output()`. For more information on the arguments expected by this method, you can run `remote_run.get_output??`.\n",
+        "Note that when the model contains BERT, this step will require pytorch and pytorch-transformers installed in your local environment. The exact versions of these packages can be found in the **automl_env.yml** file located in the local copy of your MachineLearningNotebooks folder here:\n",
+        "MachineLearningNotebooks/how-to-use-azureml/automated-machine-learning/automl_env.yml\n"
       ]
     },
     {
@@ -350,7 +352,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = automl_run.get_output()"
+        "# Retrieve the best Run object\n",
+        "best_run = automl_run.get_best_child()"
       ]
     },
     {
@@ -366,10 +369,15 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "text_transformations_used = []\n",
-        "for column_group in fitted_model.named_steps['datatransformer'].get_featurization_summary():\n",
-        "    text_transformations_used.extend(column_group['Transformations'])\n",
-        "text_transformations_used"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "\n",
+        "featurization_summary = pd.DataFrame.from_records(records)\n",
+        "featurization_summary['Transformations'].tolist()"
       ]
     },
     {

how-to-use-azureml/automated-machine-learning/continuous-retraining/auto-ml-continuous-retraining.ipynb

@@ -81,7 +81,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -127,7 +127,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Run History Name'] = experiment_name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]

how-to-use-azureml/automated-machine-learning/experimental/automl_thin_client_env.yml

@@ -1,12 +1,11 @@
 name: azure_automl_experimental
 dependencies:
   # The python interpreter version.
-  # Currently Azure ML only supports 3.5.2 and later.
-- pip<=19.3.1
-- python>=3.5.2,<3.8
-- nb_conda
-- cython
-- urllib3<1.24
+  # Currently Azure ML only supports 3.6.0 and later.
+- pip<=20.2.4
+- python>=3.6.0,<3.9
+- cython==0.29.14
+- urllib3==1.26.7
 - PyJWT < 2.0.0
 - numpy==1.18.5
 

how-to-use-azureml/automated-machine-learning/experimental/automl_thin_client_env_mac.yml

@@ -1,15 +1,16 @@
 name: azure_automl_experimental
+channels:
+  - conda-forge
+  - main
 dependencies:
   # The python interpreter version.
-  # Currently Azure ML only supports 3.5.2 and later.
-- pip<=19.3.1
+  # Currently Azure ML only supports 3.6.0 and later.
+- pip<=20.2.4
 - nomkl
-- python>=3.5.2,<3.8
-- nb_conda
-- cython
-- urllib3<1.24
+- python>=3.6.0,<3.9
+- urllib3==1.26.7
 - PyJWT < 2.0.0
-- numpy==1.18.5
+- numpy==1.19.5
 
 - pip:
   # Required packages for AzureML execution, history, and data preparation.

how-to-use-azureml/automated-machine-learning/experimental/classification-credit-card-fraud-local-managed/auto-ml-classification-credit-card-fraud-local-managed.ipynb

@@ -92,7 +92,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

how-to-use-azureml/automated-machine-learning/experimental/regression-model-proxy/auto-ml-regression-model-proxy.ipynb

@@ -91,7 +91,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

how-to-use-azureml/automated-machine-learning/forecasting-backtest-many-models/assets/score.py

@@ -0,0 +1,167 @@
+from typing import Any, Dict, Optional, List
+
+import argparse
+import json
+import os
+import re
+
+import pandas as pd
+
+from matplotlib import pyplot as plt
+from matplotlib.backends.backend_pdf import PdfPages
+
+from azureml.automl.core.shared import constants
+from azureml.automl.core.shared.types import GrainType
+from azureml.automl.runtime.shared.score import scoring
+
+GRAIN = "time_series_id"
+BACKTEST_ITER = "backtest_iteration"
+ACTUALS = "actual_level"
+PREDICTIONS = "predicted_level"
+ALL_GRAINS = "all_sets"
+
+FORECASTS_FILE = "forecast.csv"
+SCORES_FILE = "scores.csv"
+PLOTS_FILE = "plots_fcst_vs_actual.pdf"
+RE_INVALID_SYMBOLS = re.compile("[: ]")
+
+
+def _compute_metrics(df: pd.DataFrame, metrics: List[str]):
+    """
+    Compute metrics for one data frame.
+
+    :param df: The data frame which contains actual_level and predicted_level columns.
+    :return: The data frame with two columns - metric_name and metric.
+    """
+    scores = scoring.score_regression(
+        y_test=df[ACTUALS], y_pred=df[PREDICTIONS], metrics=metrics
+    )
+    metrics_df = pd.DataFrame(list(scores.items()), columns=["metric_name", "metric"])
+    metrics_df.sort_values(["metric_name"], inplace=True)
+    metrics_df.reset_index(drop=True, inplace=True)
+    return metrics_df
+
+
+def _format_grain_name(grain: GrainType) -> str:
+    """
+    Convert grain name to string.
+
+    :param grain: the grain name.
+    :return: the string representation of the given grain.
+    """
+    if not isinstance(grain, tuple) and not isinstance(grain, list):
+        return str(grain)
+    grain = list(map(str, grain))
+    return "|".join(grain)
+
+
+def compute_all_metrics(
+    fcst_df: pd.DataFrame,
+    ts_id_colnames: List[str],
+    metric_names: Optional[List[set]] = None,
+):
+    """
+    Calculate metrics per grain.
+
+    :param fcst_df: forecast data frame. Must contain 2 columns: 'actual_level' and 'predicted_level'
+    :param metric_names: (optional) the list of metric names to return
+    :param ts_id_colnames: (optional) list of grain column names
+    :return: dictionary of summary table for all tests and final decision on stationary vs nonstaionary
+    """
+    if not metric_names:
+        metric_names = list(constants.Metric.SCALAR_REGRESSION_SET)
+
+    if ts_id_colnames is None:
+        ts_id_colnames = []
+
+    metrics_list = []
+    if ts_id_colnames:
+        for grain, df in fcst_df.groupby(ts_id_colnames):
+            one_grain_metrics_df = _compute_metrics(df, metric_names)
+            one_grain_metrics_df[GRAIN] = _format_grain_name(grain)
+            metrics_list.append(one_grain_metrics_df)
+
+    # overall metrics
+    one_grain_metrics_df = _compute_metrics(fcst_df, metric_names)
+    one_grain_metrics_df[GRAIN] = ALL_GRAINS
+    metrics_list.append(one_grain_metrics_df)
+
+    # collect into a data frame
+    return pd.concat(metrics_list)
+
+
+def _draw_one_plot(
+    df: pd.DataFrame,
+    time_column_name: str,
+    grain_column_names: List[str],
+    pdf: PdfPages,
+) -> None:
+    """
+    Draw the single plot.
+
+    :param df: The data frame with the data to build plot.
+    :param time_column_name: The name of a time column.
+    :param grain_column_names: The name of grain columns.
+    :param pdf: The pdf backend used to render the plot.
+    """
+    fig, _ = plt.subplots(figsize=(20, 10))
+    df = df.set_index(time_column_name)
+    plt.plot(df[[ACTUALS, PREDICTIONS]])
+    plt.xticks(rotation=45)
+    iteration = df[BACKTEST_ITER].iloc[0]
+    if grain_column_names:
+        grain_name = [df[grain].iloc[0] for grain in grain_column_names]
+        plt.title(f"Time series ID: {_format_grain_name(grain_name)} {iteration}")
+    plt.legend(["actual", "forecast"])
+    plt.close(fig)
+    pdf.savefig(fig)
+
+
+def calculate_scores_and_build_plots(
+    input_dir: str, output_dir: str, automl_settings: Dict[str, Any]
+):
+    os.makedirs(output_dir, exist_ok=True)
+    grains = automl_settings.get(constants.TimeSeries.GRAIN_COLUMN_NAMES)
+    time_column_name = automl_settings.get(constants.TimeSeries.TIME_COLUMN_NAME)
+    if grains is None:
+        grains = []
+    if isinstance(grains, str):
+        grains = [grains]
+    while BACKTEST_ITER in grains:
+        grains.remove(BACKTEST_ITER)
+
+    dfs = []
+    for fle in os.listdir(input_dir):
+        file_path = os.path.join(input_dir, fle)
+        if os.path.isfile(file_path) and file_path.endswith(".csv"):
+            df_iter = pd.read_csv(file_path, parse_dates=[time_column_name])
+            for _, iteration in df_iter.groupby(BACKTEST_ITER):
+                dfs.append(iteration)
+    forecast_df = pd.concat(dfs, sort=False, ignore_index=True)
+    # To make sure plots are in order, sort the predictions by grain and iteration.
+    ts_index = grains + [BACKTEST_ITER]
+    forecast_df.sort_values(by=ts_index, inplace=True)
+    pdf = PdfPages(os.path.join(output_dir, PLOTS_FILE))
+    for _, one_forecast in forecast_df.groupby(ts_index):
+        _draw_one_plot(one_forecast, time_column_name, grains, pdf)
+    pdf.close()
+    forecast_df.to_csv(os.path.join(output_dir, FORECASTS_FILE), index=False)
+    metrics = compute_all_metrics(forecast_df, grains + [BACKTEST_ITER])
+    metrics.to_csv(os.path.join(output_dir, SCORES_FILE), index=False)
+
+
+if __name__ == "__main__":
+    args = {"forecasts": "--forecasts", "scores_out": "--output-dir"}
+    parser = argparse.ArgumentParser("Parsing input arguments.")
+    for argname, arg in args.items():
+        parser.add_argument(arg, dest=argname, required=True)
+    parsed_args, _ = parser.parse_known_args()
+    input_dir = parsed_args.forecasts
+    output_dir = parsed_args.scores_out
+    with open(
+        os.path.join(
+            os.path.dirname(os.path.realpath(__file__)), "automl_settings.json"
+        )
+    ) as json_file:
+        automl_settings = json.load(json_file)
+    calculate_scores_and_build_plots(input_dir, output_dir, automl_settings)

how-to-use-azureml/automated-machine-learning/forecasting-backtest-many-models/auto-ml-forecasting-backtest-many-models.ipynb

@@ -0,0 +1,725 @@
+{
+  "cells": [
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Copyright (c) Microsoft Corporation. All rights reserved.\n",
+        "\n",
+        "Licensed under the MIT License."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "![Impressions](https://PixelServer20190423114238.azurewebsites.net/api/impressions/MachineLearningNotebooks/how-to-use-azureml/automated-machine-learning/forecasting-hierarchical-timeseries/auto-ml-forecasting-hierarchical-timeseries.png)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "# Many Models with Backtesting - Automated ML\n",
+        "**_Backtest many models time series forecasts with Automated Machine Learning_**\n",
+        "\n",
+        "---"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "For this notebook we are using a synthetic dataset to demonstrate the back testing in many model scenario. This allows us to check historical performance of AutoML on a historical data. To do that we step back on the backtesting period by the data set several times and split the data to train and test sets. Then these data sets are used for training and evaluation of model.<br>\n",
+        "\n",
+        "Thus, it is a quick way of evaluating AutoML as if it was in production. Here, we do not test historical performance of a particular model, for this see the [notebook](../forecasting-backtest-single-model/auto-ml-forecasting-backtest-single-model.ipynb). Instead, the best model for every backtest iteration can be different since AutoML chooses the best model for a given training set.\n",
+        "![Backtesting](Backtesting.png)\n",
+        "\n",
+        "**NOTE: There are limits on how many runs we can do in parallel per workspace, and we currently recommend to set the parallelism to maximum of 320 runs per experiment per workspace. If users want to have more parallelism and increase this limit they might encounter Too Many Requests errors (HTTP 429).**"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Prerequisites\n",
+        "You'll need to create a compute Instance by following the instructions in the [EnvironmentSetup.md](../Setup_Resources/EnvironmentSetup.md)."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## 1.0 Set up workspace, datastore, experiment"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {
+        "gather": {
+          "logged": 1613003526897
+        }
+      },
+      "outputs": [],
+      "source": [
+        "import os\n",
+        "\n",
+        "import azureml.core\n",
+        "from azureml.core import Workspace, Datastore\n",
+        "import numpy as np\n",
+        "import pandas as pd\n",
+        "\n",
+        "from pandas.tseries.frequencies import to_offset\n",
+        "\n",
+        "# Set up your workspace\n",
+        "ws = Workspace.from_config()\n",
+        "ws.get_details()\n",
+        "\n",
+        "# Set up your datastores\n",
+        "dstore = ws.get_default_datastore()\n",
+        "\n",
+        "output = {}\n",
+        "output[\"SDK version\"] = azureml.core.VERSION\n",
+        "output[\"Subscription ID\"] = ws.subscription_id\n",
+        "output[\"Workspace\"] = ws.name\n",
+        "output[\"Resource Group\"] = ws.resource_group\n",
+        "output[\"Location\"] = ws.location\n",
+        "output[\"Default datastore name\"] = dstore.name\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
+        "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
+        "outputDf.T"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "This notebook is compatible with Azure ML SDK version 1.35.1 or later."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Choose an experiment"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {
+        "gather": {
+          "logged": 1613003540729
+        }
+      },
+      "outputs": [],
+      "source": [
+        "from azureml.core import Experiment\n",
+        "\n",
+        "experiment = Experiment(ws, \"automl-many-models-backtest\")\n",
+        "\n",
+        "print(\"Experiment name: \" + experiment.name)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## 2.0 Data\n",
+        "\n",
+        "#### 2.1 Data generation\n",
+        "For this notebook we will generate the artificial data set with two [time series IDs](https://docs.microsoft.com/en-us/python/api/azureml-automl-core/azureml.automl.core.forecasting_parameters.forecastingparameters?view=azure-ml-py). Then we will generate backtest folds and will upload it to the default BLOB storage and create a [TabularDataset](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.data.tabular_dataset.tabulardataset?view=azure-ml-py)"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "# simulate data: 2 grains - 700\n",
+        "TIME_COLNAME = \"date\"\n",
+        "TARGET_COLNAME = \"value\"\n",
+        "TIME_SERIES_ID_COLNAME = \"ts_id\"\n",
+        "\n",
+        "sample_size = 700\n",
+        "# Set the random seed for reproducibility of results.\n",
+        "np.random.seed(20)\n",
+        "X1 = pd.DataFrame(\n",
+        "    {\n",
+        "        TIME_COLNAME: pd.date_range(start=\"2018-01-01\", periods=sample_size),\n",
+        "        TARGET_COLNAME: np.random.normal(loc=100, scale=20, size=sample_size),\n",
+        "        TIME_SERIES_ID_COLNAME: \"ts_A\",\n",
+        "    }\n",
+        ")\n",
+        "X2 = pd.DataFrame(\n",
+        "    {\n",
+        "        TIME_COLNAME: pd.date_range(start=\"2018-01-01\", periods=sample_size),\n",
+        "        TARGET_COLNAME: np.random.normal(loc=100, scale=20, size=sample_size),\n",
+        "        TIME_SERIES_ID_COLNAME: \"ts_B\",\n",
+        "    }\n",
+        ")\n",
+        "\n",
+        "X = pd.concat([X1, X2], ignore_index=True, sort=False)\n",
+        "print(\"Simulated dataset contains {} rows \\n\".format(X.shape[0]))\n",
+        "X.head()"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Now we will generate 8 backtesting folds with backtesting period of 7 days and with the same forecasting horizon. We will add the column \"backtest_iteration\", which will identify the backtesting period by the last training date."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "offset_type = \"7D\"\n",
+        "NUMBER_OF_BACKTESTS = 8  # number of train/test sets to generate\n",
+        "\n",
+        "dfs_train = []\n",
+        "dfs_test = []\n",
+        "for ts_id, df_one in X.groupby(TIME_SERIES_ID_COLNAME):\n",
+        "\n",
+        "    data_end = df_one[TIME_COLNAME].max()\n",
+        "\n",
+        "    for i in range(NUMBER_OF_BACKTESTS):\n",
+        "        train_cutoff_date = data_end - to_offset(offset_type)\n",
+        "        df_one = df_one.copy()\n",
+        "        df_one[\"backtest_iteration\"] = \"iteration_\" + str(train_cutoff_date)\n",
+        "        train = df_one[df_one[TIME_COLNAME] <= train_cutoff_date]\n",
+        "        test = df_one[\n",
+        "            (df_one[TIME_COLNAME] > train_cutoff_date)\n",
+        "            & (df_one[TIME_COLNAME] <= data_end)\n",
+        "        ]\n",
+        "        data_end = train[TIME_COLNAME].max()\n",
+        "        dfs_train.append(train)\n",
+        "        dfs_test.append(test)\n",
+        "\n",
+        "X_train = pd.concat(dfs_train, sort=False, ignore_index=True)\n",
+        "X_test = pd.concat(dfs_test, sort=False, ignore_index=True)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "#### 2.2 Create the Tabular Data Set.\n",
+        "\n",
+        "A Datastore is a place where data can be stored that is then made accessible to a compute either by means of mounting or copying the data to the compute target.\n",
+        "\n",
+        "Please refer to [Datastore](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.core.datastore(class)?view=azure-ml-py) documentation on how to access data from Datastore.\n",
+        "\n",
+        "In this next step, we will upload the data and create a TabularDataset."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.data.dataset_factory import TabularDatasetFactory\n",
+        "\n",
+        "ds = ws.get_default_datastore()\n",
+        "# Upload saved data to the default data store.\n",
+        "train_data = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    X_train, target=(ds, \"data_mm\"), name=\"data_train\"\n",
+        ")\n",
+        "test_data = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    X_test, target=(ds, \"data_mm\"), name=\"data_test\"\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## 3.0 Build the training pipeline\n",
+        "Now that the dataset, WorkSpace, and datastore are set up, we can put together a pipeline for training.\n",
+        "\n",
+        "> Note that if you have an AzureML Data Scientist role, you will not have permission to create compute resources. Talk to your workspace or IT admin to create the compute targets described in this section, if they do not already exist."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Choose a compute target\n",
+        "\n",
+        "You will need to create a [compute target](https://docs.microsoft.com/en-us/azure/machine-learning/how-to-set-up-training-targets#amlcompute) for your AutoML run. In this tutorial, you create AmlCompute as your training compute resource.\n",
+        "\n",
+        "\\*\\*Creation of AmlCompute takes approximately 5 minutes.**\n",
+        "\n",
+        "If the AmlCompute with that name is already in your workspace this code will skip the creation process. As with other Azure services, there are limits on certain resources (e.g. AmlCompute) associated with the Azure Machine Learning service. Please read this [article](https://docs.microsoft.com/en-us/azure/machine-learning/how-to-manage-quotas) on the default limits and how to request more quota."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {
+        "gather": {
+          "logged": 1613007037308
+        }
+      },
+      "outputs": [],
+      "source": [
+        "from azureml.core.compute import ComputeTarget, AmlCompute\n",
+        "\n",
+        "# Name your cluster\n",
+        "compute_name = \"backtest-mm\"\n",
+        "\n",
+        "\n",
+        "if compute_name in ws.compute_targets:\n",
+        "    compute_target = ws.compute_targets[compute_name]\n",
+        "    if compute_target and type(compute_target) is AmlCompute:\n",
+        "        print(\"Found compute target: \" + compute_name)\n",
+        "else:\n",
+        "    print(\"Creating a new compute target...\")\n",
+        "    provisioning_config = AmlCompute.provisioning_configuration(\n",
+        "        vm_size=\"STANDARD_DS12_V2\", max_nodes=6\n",
+        "    )\n",
+        "    # Create the compute target\n",
+        "    compute_target = ComputeTarget.create(ws, compute_name, provisioning_config)\n",
+        "\n",
+        "    # Can poll for a minimum number of nodes and for a specific timeout.\n",
+        "    # If no min node count is provided it will use the scale settings for the cluster\n",
+        "    compute_target.wait_for_completion(\n",
+        "        show_output=True, min_node_count=None, timeout_in_minutes=20\n",
+        "    )\n",
+        "\n",
+        "    # For a more detailed view of current cluster status, use the 'status' property\n",
+        "    print(compute_target.status.serialize())"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Set up training parameters\n",
+        "\n",
+        "This dictionary defines the AutoML and many models settings. For this forecasting task we need to define several settings including the name of the time column, the maximum forecast horizon, and the partition column name definition. Please note, that in this case we are setting grain_column_names to be the time series ID column plus iteration, because we want to train a separate model for each time series and iteration.\n",
+        "\n",
+        "| Property                           | Description|\n",
+        "| :---------------                   | :------------------- |\n",
+        "| **task**                           | forecasting |\n",
+        "| **primary_metric**                 | This is the metric that you want to optimize.<br> Forecasting supports the following primary metrics <br><i>normalized_root_mean_squared_error</i><br><i>normalized_mean_absolute_error</i> |\n",
+        "| **iteration_timeout_minutes**      | Maximum amount of time in minutes that the model can train. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **iterations**                     | Number of models to train. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **experiment_timeout_hours**       | Maximum amount of time in hours that the experiment can take before it terminates. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **label_column_name**              | The name of the label column. |\n",
+        "| **max_horizon**               | The forecast horizon is how many periods forward you would like to forecast. This integer horizon is in units of the timeseries frequency (e.g. daily, weekly). Periods are inferred from your data. |\n",
+        "| **n_cross_validations**            | Number of cross validation splits. Rolling Origin Validation is used to split time-series in a temporally consistent way. |\n",
+        "| **time_column_name**               | The name of your time column. |\n",
+        "| **grain_column_names**     | The column names used to uniquely identify timeseries in data that has multiple rows with the same timestamp. |\n",
+        "| **track_child_runs**               | Flag to disable tracking of child runs. Only best run is tracked if the flag is set to False (this includes the model and metrics of the run). |\n",
+        "| **partition_column_names**         | The names of columns used to group your models. For timeseries, the groups must not split up individual time-series. That is, each group must contain one or more whole time-series. |"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {
+        "gather": {
+          "logged": 1613007061544
+        }
+      },
+      "outputs": [],
+      "source": [
+        "from azureml.train.automl.runtime._many_models.many_models_parameters import (\n",
+        "    ManyModelsTrainParameters,\n",
+        ")\n",
+        "\n",
+        "partition_column_names = [TIME_SERIES_ID_COLNAME, \"backtest_iteration\"]\n",
+        "automl_settings = {\n",
+        "    \"task\": \"forecasting\",\n",
+        "    \"primary_metric\": \"normalized_root_mean_squared_error\",\n",
+        "    \"iteration_timeout_minutes\": 10,  # This needs to be changed based on the dataset. We ask customer to explore how long training is taking before settings this value\n",
+        "    \"iterations\": 15,\n",
+        "    \"experiment_timeout_hours\": 0.25,  # This also needs to be changed based on the dataset. For larger data set this number needs to be bigger.\n",
+        "    \"label_column_name\": TARGET_COLNAME,\n",
+        "    \"n_cross_validations\": 3,\n",
+        "    \"time_column_name\": TIME_COLNAME,\n",
+        "    \"max_horizon\": 6,\n",
+        "    \"grain_column_names\": partition_column_names,\n",
+        "    \"track_child_runs\": False,\n",
+        "}\n",
+        "\n",
+        "mm_paramters = ManyModelsTrainParameters(\n",
+        "    automl_settings=automl_settings, partition_column_names=partition_column_names\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Set up many models pipeline"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Parallel run step is leveraged to train multiple models at once. To configure the ParallelRunConfig you will need to determine the appropriate number of workers and nodes for your use case. The process_count_per_node is based off the number of cores of the compute VM. The node_count will determine the number of master nodes to use, increasing the node count will speed up the training process.\n",
+        "\n",
+        "| Property                           | Description|\n",
+        "| :---------------                   | :------------------- |\n",
+        "| **experiment**                     | The experiment used for training. |\n",
+        "| **train_data**                     | The file dataset to be used as input to the training run. |\n",
+        "| **node_count**                     | The number of compute nodes to be used for running the user script. We recommend to start with 3 and increase the node_count if the training time is taking too long. |\n",
+        "| **process_count_per_node**         | Process count per node, we recommend 2:1 ratio for number of cores: number of processes per node. eg. If node has 16 cores then configure 8 or less process count per node or optimal performance. |\n",
+        "| **train_pipeline_parameters**      | The set of configuration parameters defined in the previous section. |\n",
+        "\n",
+        "Calling this method will create a new aggregated dataset which is generated dynamically on pipeline execution."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.contrib.automl.pipeline.steps import AutoMLPipelineBuilder\n",
+        "\n",
+        "\n",
+        "training_pipeline_steps = AutoMLPipelineBuilder.get_many_models_train_steps(\n",
+        "    experiment=experiment,\n",
+        "    train_data=train_data,\n",
+        "    compute_target=compute_target,\n",
+        "    node_count=2,\n",
+        "    process_count_per_node=2,\n",
+        "    run_invocation_timeout=920,\n",
+        "    train_pipeline_parameters=mm_paramters,\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.pipeline.core import Pipeline\n",
+        "\n",
+        "training_pipeline = Pipeline(ws, steps=training_pipeline_steps)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Submit the pipeline to run\n",
+        "Next we submit our pipeline to run. The whole training pipeline takes about 20 minutes using a STANDARD_DS12_V2 VM with our current ParallelRunConfig setting."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "training_run = experiment.submit(training_pipeline)"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "training_run.wait_for_completion(show_output=False)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Check the run status, if training_run is in completed state, continue to next section. Otherwise, check the portal for failures."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## 4.0 Backtesting\n",
+        "Now that we selected the best AutoML model for each backtest fold, we will use these models to generate the forecasts and compare with the actuals."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Set up output dataset for inference data\n",
+        "Output of inference can be represented as [OutputFileDatasetConfig](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.data.output_dataset_config.outputdatasetconfig?view=azure-ml-py) object and OutputFileDatasetConfig can be registered as a dataset. "
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.data import OutputFileDatasetConfig\n",
+        "\n",
+        "output_inference_data_ds = OutputFileDatasetConfig(\n",
+        "    name=\"many_models_inference_output\",\n",
+        "    destination=(dstore, \"backtesting/inference_data/\"),\n",
+        ").register_on_complete(name=\"backtesting_data_ds\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "For many models we need to provide the ManyModelsInferenceParameters object.\n",
+        "\n",
+        "#### ManyModelsInferenceParameters arguments\n",
+        "| Property                           | Description|\n",
+        "| :---------------                   | :------------------- |\n",
+        "| **partition_column_names**         | List of column names that identifies groups.                                           |\n",
+        "| **target_column_name**             | \\[Optional\\] Column name only if the inference dataset has the target. |\n",
+        "| **time_column_name**               | Column name only if it is timeseries. |\n",
+        "| **many_models_run_id**             | \\[Optional\\] Many models pipeline run id where models were trained. |\n",
+        "\n",
+        "#### get_many_models_batch_inference_steps arguments\n",
+        "| Property                           | Description|\n",
+        "| :---------------                   | :------------------- |\n",
+        "| **experiment**                     | The experiment used for inference run. |\n",
+        "| **inference_data**                 | The data to use for inferencing. It should be the same schema as used for training.\n",
+        "| **compute_target**                 | The compute target that runs the inference pipeline.|\n",
+        "| **node_count**                     | The number of compute nodes to be used for running the user script. We recommend to start with the number of cores per node (varies by compute sku). |\n",
+        "| **process_count_per_node**         | The number of processes per node.\n",
+        "| **train_run_id**                   | \\[Optional\\] The run id of the hierarchy training, by default it is the latest successful training many model run in the experiment. |\n",
+        "| **train_experiment_name**          | \\[Optional\\] The train experiment that contains the train pipeline. This one is only needed when the train pipeline is not in the same experiement as the inference pipeline. |\n",
+        "| **process_count_per_node**         | \\[Optional\\] The number of processes per node, by default it's 4. |"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.contrib.automl.pipeline.steps import AutoMLPipelineBuilder\n",
+        "from azureml.train.automl.runtime._many_models.many_models_parameters import (\n",
+        "    ManyModelsInferenceParameters,\n",
+        ")\n",
+        "\n",
+        "mm_parameters = ManyModelsInferenceParameters(\n",
+        "    partition_column_names=partition_column_names,\n",
+        "    time_column_name=TIME_COLNAME,\n",
+        "    target_column_name=TARGET_COLNAME,\n",
+        ")\n",
+        "\n",
+        "inference_steps = AutoMLPipelineBuilder.get_many_models_batch_inference_steps(\n",
+        "    experiment=experiment,\n",
+        "    inference_data=test_data,\n",
+        "    node_count=2,\n",
+        "    process_count_per_node=2,\n",
+        "    compute_target=compute_target,\n",
+        "    run_invocation_timeout=300,\n",
+        "    output_datastore=output_inference_data_ds,\n",
+        "    train_run_id=training_run.id,\n",
+        "    train_experiment_name=training_run.experiment.name,\n",
+        "    inference_pipeline_parameters=mm_parameters,\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.pipeline.core import Pipeline\n",
+        "\n",
+        "inference_pipeline = Pipeline(ws, steps=inference_steps)"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "inference_run = experiment.submit(inference_pipeline)\n",
+        "inference_run.wait_for_completion(show_output=False)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## 5.0 Retrieve results and calculate metrics\n",
+        "\n",
+        "The pipeline returns one file with the predictions for each times series ID and outputs the result to the forecasting_output Blob container. The details of the blob container is listed in 'forecasting_output.txt' under Outputs+logs. \n",
+        "\n",
+        "The next code snippet does the following:\n",
+        "1. Downloads the contents of the output folder that is passed in the parallel run step \n",
+        "2. Reads the parallel_run_step.txt file that has the predictions as pandas dataframe \n",
+        "3. Saves the table in csv format and \n",
+        "4. Displays the top 10 rows of the predictions"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.contrib.automl.pipeline.steps.utilities import get_output_from_mm_pipeline\n",
+        "\n",
+        "forecasting_results_name = \"forecasting_results\"\n",
+        "forecasting_output_name = \"many_models_inference_output\"\n",
+        "forecast_file = get_output_from_mm_pipeline(\n",
+        "    inference_run, forecasting_results_name, forecasting_output_name\n",
+        ")\n",
+        "df = pd.read_csv(forecast_file, delimiter=\" \", header=None, parse_dates=[0])\n",
+        "df.columns = list(X_train.columns) + [\"predicted_level\"]\n",
+        "print(\n",
+        "    \"Prediction has \", df.shape[0], \" rows. Here the first 10 rows are being displayed.\"\n",
+        ")\n",
+        "# Save the scv file with header to read it in the next step.\n",
+        "df.rename(columns={TARGET_COLNAME: \"actual_level\"}, inplace=True)\n",
+        "df.to_csv(os.path.join(forecasting_results_name, \"forecast.csv\"), index=False)\n",
+        "df.head(10)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## View metrics\n",
+        "We will read in the obtained results and run the helper script, which will generate metrics and create the plots of predicted versus actual values."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from assets.score import calculate_scores_and_build_plots\n",
+        "\n",
+        "backtesting_results = \"backtesting_mm_results\"\n",
+        "os.makedirs(backtesting_results, exist_ok=True)\n",
+        "calculate_scores_and_build_plots(\n",
+        "    forecasting_results_name, backtesting_results, automl_settings\n",
+        ")\n",
+        "pd.DataFrame({\"File\": os.listdir(backtesting_results)})"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "The directory contains a set of files with results:\n",
+        "- forecast.csv contains forecasts for all backtest iterations. The backtest_iteration column contains iteration identifier with the last training date as a suffix\n",
+        "- scores.csv contains all metrics. If data set contains several time series, the metrics are given for all combinations of time series id and iterations, as well as scores for all iterations and time series ids, which are marked as \"all_sets\"\n",
+        "- plots_fcst_vs_actual.pdf contains the predictions vs forecast plots for each iteration and, eash time series is saved as separate plot.\n",
+        "\n",
+        "For demonstration purposes we will display the table of metrics for one of the time series with ID \"ts0\". We will create the utility function, which will build the table with metrics."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "def get_metrics_for_ts(all_metrics, ts):\n",
+        "    \"\"\"\n",
+        "    Get the metrics for the time series with ID ts and return it as pandas data frame.\n",
+        "\n",
+        "    :param all_metrics: The table with all the metrics.\n",
+        "    :param ts: The ID of a time series of interest.\n",
+        "    :return: The pandas DataFrame with metrics for one time series.\n",
+        "    \"\"\"\n",
+        "    results_df = None\n",
+        "    for ts_id, one_series in all_metrics.groupby(\"time_series_id\"):\n",
+        "        if not ts_id.startswith(ts):\n",
+        "            continue\n",
+        "        iteration = ts_id.split(\"|\")[-1]\n",
+        "        df = one_series[[\"metric_name\", \"metric\"]]\n",
+        "        df.rename({\"metric\": iteration}, axis=1, inplace=True)\n",
+        "        df.set_index(\"metric_name\", inplace=True)\n",
+        "        if results_df is None:\n",
+        "            results_df = df\n",
+        "        else:\n",
+        "            results_df = results_df.merge(\n",
+        "                df, how=\"inner\", left_index=True, right_index=True\n",
+        "            )\n",
+        "    results_df.sort_index(axis=1, inplace=True)\n",
+        "    return results_df\n",
+        "\n",
+        "\n",
+        "metrics_df = pd.read_csv(os.path.join(backtesting_results, \"scores.csv\"))\n",
+        "ts = \"ts_A\"\n",
+        "get_metrics_for_ts(metrics_df, ts)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Forecast vs actuals plots."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from IPython.display import IFrame\n",
+        "\n",
+        "IFrame(\"./backtesting_mm_results/plots_fcst_vs_actual.pdf\", width=800, height=300)"
+      ]
+    }
+  ],
+  "metadata": {
+    "authors": [
+      {
+        "name": "jialiu"
+      }
+    ],
+    "categories": [
+      "how-to-use-azureml",
+      "automated-machine-learning"
+    ],
+    "kernelspec": {
+      "display_name": "Python 3.6",
+      "language": "python",
+      "name": "python36"
+    },
+    "language_info": {
+      "codemirror_mode": {
+        "name": "ipython",
+        "version": 3
+      },
+      "file_extension": ".py",
+      "mimetype": "text/x-python",
+      "name": "python",
+      "nbconvert_exporter": "python",
+      "pygments_lexer": "ipython3",
+      "version": "3.6.9"
+    }
+  },
+  "nbformat": 4,
+  "nbformat_minor": 4
+}

how-to-use-azureml/automated-machine-learning/forecasting-backtest-many-models/auto-ml-forecasting-backtest-many-models.yml

@@ -0,0 +1,4 @@
+name: auto-ml-forecasting-backtest-many-models
+dependencies:
+- pip:
+  - azureml-sdk

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/assets/data_split.py

@@ -0,0 +1,45 @@
+import argparse
+import os
+
+import pandas as pd
+
+import azureml.train.automl.runtime._hts.hts_runtime_utilities as hru
+
+from azureml.core import Run
+from azureml.core.dataset import Dataset
+
+# Parse the arguments.
+args = {
+    "step_size": "--step-size",
+    "step_number": "--step-number",
+    "time_column_name": "--time-column-name",
+    "time_series_id_column_names": "--time-series-id-column-names",
+    "out_dir": "--output-dir",
+}
+parser = argparse.ArgumentParser("Parsing input arguments.")
+for argname, arg in args.items():
+    parser.add_argument(arg, dest=argname, required=True)
+parsed_args, _ = parser.parse_known_args()
+step_number = int(parsed_args.step_number)
+step_size = int(parsed_args.step_size)
+# Create the working dirrectory to store the temporary csv files.
+working_dir = parsed_args.out_dir
+os.makedirs(working_dir, exist_ok=True)
+# Set input and output
+script_run = Run.get_context()
+input_dataset = script_run.input_datasets["training_data"]
+X_train = input_dataset.to_pandas_dataframe()
+# Split the data.
+for i in range(step_number):
+    file_name = os.path.join(working_dir, "backtest_{}.csv".format(i))
+    if parsed_args.time_series_id_column_names:
+        dfs = []
+        for _, one_series in X_train.groupby([parsed_args.time_series_id_column_names]):
+            one_series = one_series.sort_values(
+                by=[parsed_args.time_column_name], inplace=False
+            )
+            dfs.append(one_series.iloc[: len(one_series) - step_size * i])
+        pd.concat(dfs, sort=False, ignore_index=True).to_csv(file_name, index=False)
+    else:
+        X_train.sort_values(by=[parsed_args.time_column_name], inplace=True)
+        X_train.iloc[: len(X_train) - step_size * i].to_csv(file_name, index=False)

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/assets/retrain_models.py

@@ -0,0 +1,173 @@
+# ---------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# ---------------------------------------------------------
+"""The batch script needed for back testing of models using PRS."""
+import argparse
+import json
+import logging
+import os
+import pickle
+import re
+
+import pandas as pd
+
+from azureml.core.experiment import Experiment
+from azureml.core.model import Model
+from azureml.core.run import Run
+from azureml.automl.core.shared import constants
+from azureml.automl.runtime.shared.score import scoring
+from azureml.train.automl import AutoMLConfig
+
+RE_INVALID_SYMBOLS = re.compile(r"[:\s]")
+
+model_name = None
+target_column_name = None
+current_step_run = None
+output_dir = None
+
+logger = logging.getLogger(__name__)
+
+
+def _get_automl_settings():
+    with open(
+        os.path.join(
+            os.path.dirname(os.path.realpath(__file__)), "automl_settings.json"
+        )
+    ) as json_file:
+        return json.load(json_file)
+
+
+def init():
+    global model_name
+    global target_column_name
+    global output_dir
+    global automl_settings
+    global model_uid
+    logger.info("Initialization of the run.")
+    parser = argparse.ArgumentParser("Parsing input arguments.")
+    parser.add_argument("--output-dir", dest="out", required=True)
+    parser.add_argument("--model-name", dest="model", default=None)
+    parser.add_argument("--model-uid", dest="model_uid", default=None)
+
+    parsed_args, _ = parser.parse_known_args()
+    model_name = parsed_args.model
+    automl_settings = _get_automl_settings()
+    target_column_name = automl_settings.get("label_column_name")
+    output_dir = parsed_args.out
+    model_uid = parsed_args.model_uid
+    os.makedirs(output_dir, exist_ok=True)
+    os.environ["AUTOML_IGNORE_PACKAGE_VERSION_INCOMPATIBILITIES".lower()] = "True"
+
+
+def get_run():
+    global current_step_run
+    if current_step_run is None:
+        current_step_run = Run.get_context()
+    return current_step_run
+
+
+def run_backtest(data_input_name: str, file_name: str, experiment: Experiment):
+    """Re-train the model and return metrics."""
+    data_input = pd.read_csv(
+        data_input_name,
+        parse_dates=[automl_settings[constants.TimeSeries.TIME_COLUMN_NAME]],
+    )
+    print(data_input.head())
+    if not automl_settings.get(constants.TimeSeries.GRAIN_COLUMN_NAMES):
+        # There is no grains.
+        data_input.sort_values(
+            [automl_settings[constants.TimeSeries.TIME_COLUMN_NAME]], inplace=True
+        )
+        X_train = data_input.iloc[: -automl_settings["max_horizon"]]
+        y_train = X_train.pop(target_column_name).values
+        X_test = data_input.iloc[-automl_settings["max_horizon"] :]
+        y_test = X_test.pop(target_column_name).values
+    else:
+        # The data contain grains.
+        dfs_train = []
+        dfs_test = []
+        for _, one_series in data_input.groupby(
+            automl_settings.get(constants.TimeSeries.GRAIN_COLUMN_NAMES)
+        ):
+            one_series.sort_values(
+                [automl_settings[constants.TimeSeries.TIME_COLUMN_NAME]], inplace=True
+            )
+            dfs_train.append(one_series.iloc[: -automl_settings["max_horizon"]])
+            dfs_test.append(one_series.iloc[-automl_settings["max_horizon"] :])
+        X_train = pd.concat(dfs_train, sort=False, ignore_index=True)
+        y_train = X_train.pop(target_column_name).values
+        X_test = pd.concat(dfs_test, sort=False, ignore_index=True)
+        y_test = X_test.pop(target_column_name).values
+
+    last_training_date = str(
+        X_train[automl_settings[constants.TimeSeries.TIME_COLUMN_NAME]].max()
+    )
+
+    if file_name:
+        # If file name is provided, we will load model and retrain it on backtest data.
+        with open(file_name, "rb") as fp:
+            fitted_model = pickle.load(fp)
+        fitted_model.fit(X_train, y_train)
+    else:
+        # We will run the experiment and select the best model.
+        X_train[target_column_name] = y_train
+        automl_config = AutoMLConfig(training_data=X_train, **automl_settings)
+        automl_run = current_step_run.submit_child(automl_config, show_output=True)
+        best_run, fitted_model = automl_run.get_output()
+        # As we have generated models, we need to register them for the future use.
+        description = "Backtest model example"
+        tags = {"last_training_date": last_training_date, "experiment": experiment.name}
+        if model_uid:
+            tags["model_uid"] = model_uid
+        automl_run.register_model(
+            model_name=best_run.properties["model_name"],
+            description=description,
+            tags=tags,
+        )
+        print(f"The model {best_run.properties['model_name']} was registered.")
+
+    _, x_pred = fitted_model.forecast(X_test)
+    x_pred.reset_index(inplace=True, drop=False)
+    columns = [automl_settings[constants.TimeSeries.TIME_COLUMN_NAME]]
+    if automl_settings.get(constants.TimeSeries.GRAIN_COLUMN_NAMES):
+        # We know that fitted_model.grain_column_names is a list.
+        columns.extend(fitted_model.grain_column_names)
+    columns.append(constants.TimeSeriesInternal.DUMMY_TARGET_COLUMN)
+    # Remove featurized columns.
+    x_pred = x_pred[columns]
+    x_pred.rename(
+        {constants.TimeSeriesInternal.DUMMY_TARGET_COLUMN: "predicted_level"},
+        axis=1,
+        inplace=True,
+    )
+    x_pred["actual_level"] = y_test
+    x_pred["backtest_iteration"] = f"iteration_{last_training_date}"
+    date_safe = RE_INVALID_SYMBOLS.sub("_", last_training_date)
+    x_pred.to_csv(os.path.join(output_dir, f"iteration_{date_safe}.csv"), index=False)
+    return x_pred
+
+
+def run(input_files):
+    """Run the script"""
+    logger.info("Running mini batch.")
+    ws = get_run().experiment.workspace
+    file_name = None
+    if model_name:
+        models = Model.list(ws, name=model_name)
+        cloud_model = None
+        if models:
+            for one_mod in models:
+                if cloud_model is None or one_mod.version > cloud_model.version:
+                    logger.info(
+                        "Using existing model from the workspace. Model version: {}".format(
+                            one_mod.version
+                        )
+                    )
+                    cloud_model = one_mod
+        file_name = cloud_model.download(exist_ok=True)
+
+    forecasts = []
+    logger.info("Running backtest.")
+    for input_file in input_files:
+        forecasts.append(run_backtest(input_file, file_name, get_run().experiment))
+    return pd.concat(forecasts)

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/assets/score.py

@@ -0,0 +1,167 @@
+from typing import Any, Dict, Optional, List
+
+import argparse
+import json
+import os
+import re
+
+import pandas as pd
+
+from matplotlib import pyplot as plt
+from matplotlib.backends.backend_pdf import PdfPages
+
+from azureml.automl.core.shared import constants
+from azureml.automl.core.shared.types import GrainType
+from azureml.automl.runtime.shared.score import scoring
+
+GRAIN = "time_series_id"
+BACKTEST_ITER = "backtest_iteration"
+ACTUALS = "actual_level"
+PREDICTIONS = "predicted_level"
+ALL_GRAINS = "all_sets"
+
+FORECASTS_FILE = "forecast.csv"
+SCORES_FILE = "scores.csv"
+PLOTS_FILE = "plots_fcst_vs_actual.pdf"
+RE_INVALID_SYMBOLS = re.compile("[: ]")
+
+
+def _compute_metrics(df: pd.DataFrame, metrics: List[str]):
+    """
+    Compute metrics for one data frame.
+
+    :param df: The data frame which contains actual_level and predicted_level columns.
+    :return: The data frame with two columns - metric_name and metric.
+    """
+    scores = scoring.score_regression(
+        y_test=df[ACTUALS], y_pred=df[PREDICTIONS], metrics=metrics
+    )
+    metrics_df = pd.DataFrame(list(scores.items()), columns=["metric_name", "metric"])
+    metrics_df.sort_values(["metric_name"], inplace=True)
+    metrics_df.reset_index(drop=True, inplace=True)
+    return metrics_df
+
+
+def _format_grain_name(grain: GrainType) -> str:
+    """
+    Convert grain name to string.
+
+    :param grain: the grain name.
+    :return: the string representation of the given grain.
+    """
+    if not isinstance(grain, tuple) and not isinstance(grain, list):
+        return str(grain)
+    grain = list(map(str, grain))
+    return "|".join(grain)
+
+
+def compute_all_metrics(
+    fcst_df: pd.DataFrame,
+    ts_id_colnames: List[str],
+    metric_names: Optional[List[set]] = None,
+):
+    """
+    Calculate metrics per grain.
+
+    :param fcst_df: forecast data frame. Must contain 2 columns: 'actual_level' and 'predicted_level'
+    :param metric_names: (optional) the list of metric names to return
+    :param ts_id_colnames: (optional) list of grain column names
+    :return: dictionary of summary table for all tests and final decision on stationary vs nonstaionary
+    """
+    if not metric_names:
+        metric_names = list(constants.Metric.SCALAR_REGRESSION_SET)
+
+    if ts_id_colnames is None:
+        ts_id_colnames = []
+
+    metrics_list = []
+    if ts_id_colnames:
+        for grain, df in fcst_df.groupby(ts_id_colnames):
+            one_grain_metrics_df = _compute_metrics(df, metric_names)
+            one_grain_metrics_df[GRAIN] = _format_grain_name(grain)
+            metrics_list.append(one_grain_metrics_df)
+
+    # overall metrics
+    one_grain_metrics_df = _compute_metrics(fcst_df, metric_names)
+    one_grain_metrics_df[GRAIN] = ALL_GRAINS
+    metrics_list.append(one_grain_metrics_df)
+
+    # collect into a data frame
+    return pd.concat(metrics_list)
+
+
+def _draw_one_plot(
+    df: pd.DataFrame,
+    time_column_name: str,
+    grain_column_names: List[str],
+    pdf: PdfPages,
+) -> None:
+    """
+    Draw the single plot.
+
+    :param df: The data frame with the data to build plot.
+    :param time_column_name: The name of a time column.
+    :param grain_column_names: The name of grain columns.
+    :param pdf: The pdf backend used to render the plot.
+    """
+    fig, _ = plt.subplots(figsize=(20, 10))
+    df = df.set_index(time_column_name)
+    plt.plot(df[[ACTUALS, PREDICTIONS]])
+    plt.xticks(rotation=45)
+    iteration = df[BACKTEST_ITER].iloc[0]
+    if grain_column_names:
+        grain_name = [df[grain].iloc[0] for grain in grain_column_names]
+        plt.title(f"Time series ID: {_format_grain_name(grain_name)} {iteration}")
+    plt.legend(["actual", "forecast"])
+    plt.close(fig)
+    pdf.savefig(fig)
+
+
+def calculate_scores_and_build_plots(
+    input_dir: str, output_dir: str, automl_settings: Dict[str, Any]
+):
+    os.makedirs(output_dir, exist_ok=True)
+    grains = automl_settings.get(constants.TimeSeries.GRAIN_COLUMN_NAMES)
+    time_column_name = automl_settings.get(constants.TimeSeries.TIME_COLUMN_NAME)
+    if grains is None:
+        grains = []
+    if isinstance(grains, str):
+        grains = [grains]
+    while BACKTEST_ITER in grains:
+        grains.remove(BACKTEST_ITER)
+
+    dfs = []
+    for fle in os.listdir(input_dir):
+        file_path = os.path.join(input_dir, fle)
+        if os.path.isfile(file_path) and file_path.endswith(".csv"):
+            df_iter = pd.read_csv(file_path, parse_dates=[time_column_name])
+            for _, iteration in df_iter.groupby(BACKTEST_ITER):
+                dfs.append(iteration)
+    forecast_df = pd.concat(dfs, sort=False, ignore_index=True)
+    # To make sure plots are in order, sort the predictions by grain and iteration.
+    ts_index = grains + [BACKTEST_ITER]
+    forecast_df.sort_values(by=ts_index, inplace=True)
+    pdf = PdfPages(os.path.join(output_dir, PLOTS_FILE))
+    for _, one_forecast in forecast_df.groupby(ts_index):
+        _draw_one_plot(one_forecast, time_column_name, grains, pdf)
+    pdf.close()
+    forecast_df.to_csv(os.path.join(output_dir, FORECASTS_FILE), index=False)
+    metrics = compute_all_metrics(forecast_df, grains + [BACKTEST_ITER])
+    metrics.to_csv(os.path.join(output_dir, SCORES_FILE), index=False)
+
+
+if __name__ == "__main__":
+    args = {"forecasts": "--forecasts", "scores_out": "--output-dir"}
+    parser = argparse.ArgumentParser("Parsing input arguments.")
+    for argname, arg in args.items():
+        parser.add_argument(arg, dest=argname, required=True)
+    parsed_args, _ = parser.parse_known_args()
+    input_dir = parsed_args.forecasts
+    output_dir = parsed_args.scores_out
+    with open(
+        os.path.join(
+            os.path.dirname(os.path.realpath(__file__)), "automl_settings.json"
+        )
+    ) as json_file:
+        automl_settings = json.load(json_file)
+    calculate_scores_and_build_plots(input_dir, output_dir, automl_settings)

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/auto-ml-forecasting-backtest-single-model.ipynb

@@ -0,0 +1,719 @@
+{
+  "cells": [
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Copyright (c) Microsoft Corporation. All rights reserved.\n",
+        "\n",
+        "Licensed under the MIT License.\n",
+        "![Impressions](https://PixelServer20190423114238.azurewebsites.net/api/impressions/MachineLearningNotebooks/how-to-use-azureml/automated-machine-learning/automl-forecasting-function.png)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "# Automated MachineLearning\n",
+        "_**The model backtesting**_\n",
+        "\n",
+        "## Contents\n",
+        "1. [Introduction](#Introduction)\n",
+        "2. [Setup](#Setup)\n",
+        "3. [Data](#Data)\n",
+        "4. [Prepare remote compute and data.](#prepare_remote)\n",
+        "5. [Create the configuration for AutoML backtesting](#train)\n",
+        "6. [Backtest AutoML](#backtest_automl)\n",
+        "7. [View metrics](#Metrics)\n",
+        "8. [Backtest the best model](#backtest_model)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## Introduction\n",
+        "Model backtesting is used to evaluate its performance on historical data. To do that we step back on the backtesting period by the data set several times and split the data to train and test sets. Then these data sets are used for training and evaluation of model.<br>\n",
+        "This notebook is intended to demonstrate backtesting on a single model, this is the best solution for small data sets with a few or one time series in it. For scenarios where we would like to choose the best AutoML model for every backtest iteration, please see [AutoML Forecasting Backtest Many Models Example](../forecasting-backtest-many-models/auto-ml-forecasting-backtest-many-models.ipynb) notebook.\n",
+        "![Backtesting](Backtesting.png)\n",
+        "This notebook demonstrates two ways of backtesting:\n",
+        "- AutoML backtesting: we will train separate AutoML models for historical data\n",
+        "- Model backtesting: from the first run we will select the best model trained on the most recent data, retrain it on the past data and evaluate."
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## Setup"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "import os\n",
+        "import numpy as np\n",
+        "import pandas as pd\n",
+        "import shutil\n",
+        "\n",
+        "import azureml.core\n",
+        "from azureml.core import Experiment, Model, Workspace"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "This notebook is compatible with Azure ML SDK version 1.35.1 or later."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "As part of the setup you have already created a <b>Workspace</b>."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "ws = Workspace.from_config()\n",
+        "\n",
+        "output = {}\n",
+        "output[\"Subscription ID\"] = ws.subscription_id\n",
+        "output[\"Workspace\"] = ws.name\n",
+        "output[\"SKU\"] = ws.sku\n",
+        "output[\"Resource Group\"] = ws.resource_group\n",
+        "output[\"Location\"] = ws.location\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
+        "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
+        "outputDf.T"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## Data\n",
+        "For the demonstration purposes we will simulate one year of daily data. To do this we need to specify the following parameters: time column name, time series ID column names and label column name. Our intention is to forecast for two weeks ahead."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "TIME_COLUMN_NAME = \"date\"\n",
+        "TIME_SERIES_ID_COLUMN_NAMES = \"time_series_id\"\n",
+        "LABEL_COLUMN_NAME = \"y\"\n",
+        "FORECAST_HORIZON = 14\n",
+        "FREQUENCY = \"D\"\n",
+        "\n",
+        "\n",
+        "def simulate_timeseries_data(\n",
+        "    train_len: int,\n",
+        "    test_len: int,\n",
+        "    time_column_name: str,\n",
+        "    target_column_name: str,\n",
+        "    time_series_id_column_name: str,\n",
+        "    time_series_number: int = 1,\n",
+        "    freq: str = \"H\",\n",
+        "):\n",
+        "    \"\"\"\n",
+        "    Return the time series of designed length.\n",
+        "\n",
+        "    :param train_len: The length of training data (one series).\n",
+        "    :type train_len: int\n",
+        "    :param test_len: The length of testing data (one series).\n",
+        "    :type test_len: int\n",
+        "    :param time_column_name: The desired name of a time column.\n",
+        "    :type time_column_name: str\n",
+        "    :param time_series_number: The number of time series in the data set.\n",
+        "    :type time_series_number: int\n",
+        "    :param freq: The frequency string representing pandas offset.\n",
+        "                 see https://pandas.pydata.org/pandas-docs/stable/user_guide/timeseries.html\n",
+        "    :type freq: str\n",
+        "    :returns: the tuple of train and test data sets.\n",
+        "    :rtype: tuple\n",
+        "\n",
+        "    \"\"\"\n",
+        "    data_train = []  # type: List[pd.DataFrame]\n",
+        "    data_test = []  # type: List[pd.DataFrame]\n",
+        "    data_length = train_len + test_len\n",
+        "    for i in range(time_series_number):\n",
+        "        X = pd.DataFrame(\n",
+        "            {\n",
+        "                time_column_name: pd.date_range(\n",
+        "                    start=\"2000-01-01\", periods=data_length, freq=freq\n",
+        "                ),\n",
+        "                target_column_name: np.arange(data_length).astype(float)\n",
+        "                + np.random.rand(data_length)\n",
+        "                + i * 5,\n",
+        "                \"ext_predictor\": np.asarray(range(42, 42 + data_length)),\n",
+        "                time_series_id_column_name: np.repeat(\"ts{}\".format(i), data_length),\n",
+        "            }\n",
+        "        )\n",
+        "        data_train.append(X[:train_len])\n",
+        "        data_test.append(X[train_len:])\n",
+        "    train = pd.concat(data_train)\n",
+        "    label_train = train.pop(target_column_name).values\n",
+        "    test = pd.concat(data_test)\n",
+        "    label_test = test.pop(target_column_name).values\n",
+        "    return train, label_train, test, label_test\n",
+        "\n",
+        "\n",
+        "n_test_periods = FORECAST_HORIZON\n",
+        "n_train_periods = 365\n",
+        "X_train, y_train, X_test, y_test = simulate_timeseries_data(\n",
+        "    train_len=n_train_periods,\n",
+        "    test_len=n_test_periods,\n",
+        "    time_column_name=TIME_COLUMN_NAME,\n",
+        "    target_column_name=LABEL_COLUMN_NAME,\n",
+        "    time_series_id_column_name=TIME_SERIES_ID_COLUMN_NAMES,\n",
+        "    time_series_number=2,\n",
+        "    freq=FREQUENCY,\n",
+        ")\n",
+        "X_train[LABEL_COLUMN_NAME] = y_train"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Let's see what the training data looks like."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "X_train.tail()"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Prepare remote compute and data. <a id=\"prepare_remote\"></a>\n",
+        "The [Machine Learning service workspace](https://docs.microsoft.com/en-us/azure/machine-learning/service/concept-workspace), is paired with the storage account, which contains the default data store. We will use it to upload the artificial data and create [tabular dataset](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.data.tabulardataset?view=azure-ml-py) for training. A tabular dataset defines a series of lazily-evaluated, immutable operations to load data from the data source into tabular representation."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.data.dataset_factory import TabularDatasetFactory\n",
+        "\n",
+        "ds = ws.get_default_datastore()\n",
+        "# Upload saved data to the default data store.\n",
+        "train_data = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    X_train, target=(ds, \"data\"), name=\"data_backtest\"\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "You will need to create a compute target for backtesting. In this [tutorial](https://docs.microsoft.com/en-us/azure/machine-learning/service/how-to-set-up-training-targets#amlcompute), you create AmlCompute as your training compute resource.\n",
+        "\n",
+        "> Note that if you have an AzureML Data Scientist role, you will not have permission to create compute resources. Talk to your workspace or IT admin to create the compute targets described in this section, if they do not already exist."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from azureml.core.compute import ComputeTarget, AmlCompute\n",
+        "from azureml.core.compute_target import ComputeTargetException\n",
+        "\n",
+        "# Choose a name for your CPU cluster\n",
+        "amlcompute_cluster_name = \"backtest-cluster\"\n",
+        "\n",
+        "# Verify that cluster does not exist already\n",
+        "try:\n",
+        "    compute_target = ComputeTarget(workspace=ws, name=amlcompute_cluster_name)\n",
+        "    print(\"Found existing cluster, use it.\")\n",
+        "except ComputeTargetException:\n",
+        "    compute_config = AmlCompute.provisioning_configuration(\n",
+        "        vm_size=\"STANDARD_DS12_V2\", max_nodes=6\n",
+        "    )\n",
+        "    compute_target = ComputeTarget.create(ws, amlcompute_cluster_name, compute_config)\n",
+        "\n",
+        "compute_target.wait_for_completion(show_output=True)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## Create the configuration for AutoML backtesting <a id=\"train\"></a>\n",
+        "\n",
+        "This dictionary defines the AutoML and many models settings. For this forecasting task we need to define several settings including the name of the time column, the maximum forecast horizon, and the partition column name definition.\n",
+        "\n",
+        "| Property                           | Description|\n",
+        "| :---------------                   | :------------------- |\n",
+        "| **task**                           | forecasting |\n",
+        "| **primary_metric**                 | This is the metric that you want to optimize.<br> Forecasting supports the following primary metrics <br><i>normalized_root_mean_squared_error</i><br><i>normalized_mean_absolute_error</i> |\n",
+        "| **iteration_timeout_minutes**      | Maximum amount of time in minutes that the model can train. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **iterations**                     | Number of models to train. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **experiment_timeout_hours**       | Maximum amount of time in hours that the experiment can take before it terminates. This is optional but provides customers with greater control on exit criteria. |\n",
+        "| **label_column_name**              | The name of the label column. |\n",
+        "| **max_horizon**               | The forecast horizon is how many periods forward you would like to forecast. This integer horizon is in units of the timeseries frequency (e.g. daily, weekly). Periods are inferred from your data. |\n",
+        "| **n_cross_validations**            | Number of cross validation splits. Rolling Origin Validation is used to split time-series in a temporally consistent way. |\n",
+        "| **time_column_name**               | The name of your time column. |\n",
+        "| **grain_column_names**     | The column names used to uniquely identify timeseries in data that has multiple rows with the same timestamp. |"
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "automl_settings = {\n",
+        "    \"task\": \"forecasting\",\n",
+        "    \"primary_metric\": \"normalized_root_mean_squared_error\",\n",
+        "    \"iteration_timeout_minutes\": 10,  # This needs to be changed based on the dataset. We ask customer to explore how long training is taking before settings this value\n",
+        "    \"iterations\": 15,\n",
+        "    \"experiment_timeout_hours\": 1,  # This also needs to be changed based on the dataset. For larger data set this number needs to be bigger.\n",
+        "    \"label_column_name\": LABEL_COLUMN_NAME,\n",
+        "    \"n_cross_validations\": 3,\n",
+        "    \"time_column_name\": TIME_COLUMN_NAME,\n",
+        "    \"max_horizon\": FORECAST_HORIZON,\n",
+        "    \"track_child_runs\": False,\n",
+        "    \"grain_column_names\": TIME_SERIES_ID_COLUMN_NAMES,\n",
+        "}"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## Backtest AutoML <a id=\"backtest_automl\"></a>\n",
+        "First we set backtesting parameters: we will step back by 30 days and will make 5 such steps; for each step we will forecast for next two weeks."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "# The number of periods to step back on each backtest iteration.\n",
+        "BACKTESTING_PERIOD = 30\n",
+        "# The number of times we will back test the model.\n",
+        "NUMBER_OF_BACKTESTS = 5"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "To train AutoML on backtesting folds we will use the [Azure Machine Learning pipeline](https://docs.microsoft.com/en-us/azure/machine-learning/concept-ml-pipelines). It will generate backtest folds, then train model for each of them and calculate the accuracy metrics. To run pipeline, you also need to create an <b>Experiment</b>. An Experiment corresponds to a prediction problem you are trying to solve (here, it is a forecasting), while a Run corresponds to a specific approach to the problem."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from uuid import uuid1\n",
+        "\n",
+        "from pipeline_helper import get_backtest_pipeline\n",
+        "\n",
+        "pipeline_exp = Experiment(ws, \"automl-backtesting\")\n",
+        "\n",
+        "# We will create the unique identifier to mark our models.\n",
+        "model_uid = str(uuid1())\n",
+        "\n",
+        "pipeline = get_backtest_pipeline(\n",
+        "    experiment=pipeline_exp,\n",
+        "    dataset=train_data,\n",
+        "    # The STANDARD_DS12_V2 has 4 vCPU per node, we will set 2 process per node to be safe.\n",
+        "    process_per_node=2,\n",
+        "    # The maximum number of nodes for our compute is 6.\n",
+        "    node_count=6,\n",
+        "    compute_target=compute_target,\n",
+        "    automl_settings=automl_settings,\n",
+        "    step_size=BACKTESTING_PERIOD,\n",
+        "    step_number=NUMBER_OF_BACKTESTS,\n",
+        "    model_uid=model_uid,\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Run the pipeline and wait for results."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "pipeline_run = pipeline_exp.submit(pipeline)\n",
+        "pipeline_run.wait_for_completion(show_output=False)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "After the run is complete, we can download the results. "
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "metrics_output = pipeline_run.get_pipeline_output(\"results\")\n",
+        "metrics_output.download(\"backtest_metrics\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "## View metrics<a id=\"Metrics\"></a>\n",
+        "To distinguish these metrics from the model backtest, which we will obtain in the next section, we will move the directory with metrics out of the backtest_metrics and will remove the parent folder. We will create the utility function for that."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "def copy_scoring_directory(new_name):\n",
+        "    scores_path = os.path.join(\"backtest_metrics\", \"azureml\")\n",
+        "    directory_list = [os.path.join(scores_path, d) for d in os.listdir(scores_path)]\n",
+        "    latest_file = max(directory_list, key=os.path.getctime)\n",
+        "    print(\n",
+        "        f\"The output directory {latest_file} was created on {pd.Timestamp(os.path.getctime(latest_file), unit='s')} GMT.\"\n",
+        "    )\n",
+        "    shutil.move(os.path.join(latest_file, \"results\"), new_name)\n",
+        "    shutil.rmtree(\"backtest_metrics\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Move the directory and list its contents."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "copy_scoring_directory(\"automl_backtest\")\n",
+        "pd.DataFrame({\"File\": os.listdir(\"automl_backtest\")})"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "The directory contains a set of files with results:\n",
+        "- forecast.csv contains forecasts for all backtest iterations. The backtest_iteration column contains iteration identifier with the last training date as a suffix\n",
+        "- scores.csv contains all metrics. If data set contains several time series, the metrics are given for all combinations of time series id and iterations, as well as scores for all iterations and time series id are marked as \"all_sets\"\n",
+        "- plots_fcst_vs_actual.pdf contains the predictions vs forecast plots for each iteration and time series.\n",
+        "\n",
+        "For demonstration purposes we will display the table of metrics for one of the time series with ID \"ts0\". Again, we will create the utility function, which will be re used in model backtesting."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "def get_metrics_for_ts(all_metrics, ts):\n",
+        "    \"\"\"\n",
+        "    Get the metrics for the time series with ID ts and return it as pandas data frame.\n",
+        "\n",
+        "    :param all_metrics: The table with all the metrics.\n",
+        "    :param ts: The ID of a time series of interest.\n",
+        "    :return: The pandas DataFrame with metrics for one time series.\n",
+        "    \"\"\"\n",
+        "    results_df = None\n",
+        "    for ts_id, one_series in all_metrics.groupby(\"time_series_id\"):\n",
+        "        if not ts_id.startswith(ts):\n",
+        "            continue\n",
+        "        iteration = ts_id.split(\"|\")[-1]\n",
+        "        df = one_series[[\"metric_name\", \"metric\"]]\n",
+        "        df.rename({\"metric\": iteration}, axis=1, inplace=True)\n",
+        "        df.set_index(\"metric_name\", inplace=True)\n",
+        "        if results_df is None:\n",
+        "            results_df = df\n",
+        "        else:\n",
+        "            results_df = results_df.merge(\n",
+        "                df, how=\"inner\", left_index=True, right_index=True\n",
+        "            )\n",
+        "    results_df.sort_index(axis=1, inplace=True)\n",
+        "    return results_df\n",
+        "\n",
+        "\n",
+        "metrics_df = pd.read_csv(os.path.join(\"automl_backtest\", \"scores.csv\"))\n",
+        "ts_id = \"ts0\"\n",
+        "get_metrics_for_ts(metrics_df, ts_id)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Forecast vs actuals plots."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from IPython.display import IFrame\n",
+        "\n",
+        "IFrame(\"./automl_backtest/plots_fcst_vs_actual.pdf\", width=800, height=300)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "# <font color='blue'>Backtest the best model</font> <a id=\"backtest_model\"></a>\n",
+        "\n",
+        "For model backtesting we will use the same parameters we used to backtest AutoML. All the models, we have obtained in the previous run were registered in our workspace. To identify the model, each was assigned a tag with the last trainig date."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "model_list = Model.list(ws, tags={\"experiment\": \"automl-backtesting\"})\n",
+        "model_data = {\"name\": [], \"last_training_date\": []}\n",
+        "for model in model_list:\n",
+        "    if (\n",
+        "        \"last_training_date\" not in model.tags\n",
+        "        or \"model_uid\" not in model.tags\n",
+        "        or model.tags[\"model_uid\"] != model_uid\n",
+        "    ):\n",
+        "        continue\n",
+        "    model_data[\"name\"].append(model.name)\n",
+        "    model_data[\"last_training_date\"].append(\n",
+        "        pd.Timestamp(model.tags[\"last_training_date\"])\n",
+        "    )\n",
+        "df_models = pd.DataFrame(model_data)\n",
+        "df_models.sort_values([\"last_training_date\"], inplace=True)\n",
+        "df_models.reset_index(inplace=True, drop=True)\n",
+        "df_models"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "We will backtest the model trained on the most recet data."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "model_name = df_models[\"name\"].iloc[-1]\n",
+        "model_name"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "### Retrain the models.\n",
+        "Assemble the pipeline, which will retrain the best model from AutoML run on historical data."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "pipeline_exp = Experiment(ws, \"model-backtesting\")\n",
+        "\n",
+        "pipeline = get_backtest_pipeline(\n",
+        "    experiment=pipeline_exp,\n",
+        "    dataset=train_data,\n",
+        "    # The STANDARD_DS12_V2 has 4 vCPU per node, we will set 2 process per node to be safe.\n",
+        "    process_per_node=2,\n",
+        "    # The maximum number of nodes for our compute is 6.\n",
+        "    node_count=6,\n",
+        "    compute_target=compute_target,\n",
+        "    automl_settings=automl_settings,\n",
+        "    step_size=BACKTESTING_PERIOD,\n",
+        "    step_number=NUMBER_OF_BACKTESTS,\n",
+        "    model_name=model_name,\n",
+        ")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Launch the backtesting pipeline."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "pipeline_run = pipeline_exp.submit(pipeline)\n",
+        "pipeline_run.wait_for_completion(show_output=False)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "The metrics are stored in the pipeline output named \"score\". The next code will download the table with metrics."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "metrics_output = pipeline_run.get_pipeline_output(\"results\")\n",
+        "metrics_output.download(\"backtest_metrics\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Again, we will copy the data files from the downloaded directory, but in this case we will call the folder \"model_backtest\"; it will contain the same files as the one for AutoML backtesting."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "copy_scoring_directory(\"model_backtest\")"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Finally, we will display the metrics."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "model_metrics_df = pd.read_csv(os.path.join(\"model_backtest\", \"scores.csv\"))\n",
+        "get_metrics_for_ts(model_metrics_df, ts_id)"
+      ]
+    },
+    {
+      "cell_type": "markdown",
+      "metadata": {},
+      "source": [
+        "Forecast vs actuals plots."
+      ]
+    },
+    {
+      "cell_type": "code",
+      "execution_count": null,
+      "metadata": {},
+      "outputs": [],
+      "source": [
+        "from IPython.display import IFrame\n",
+        "\n",
+        "IFrame(\"./model_backtest/plots_fcst_vs_actual.pdf\", width=800, height=300)"
+      ]
+    }
+  ],
+  "metadata": {
+    "authors": [
+      {
+        "name": "jialiu"
+      }
+    ],
+    "category": "tutorial",
+    "compute": [
+      "Remote"
+    ],
+    "datasets": [
+      "None"
+    ],
+    "deployment": [
+      "None"
+    ],
+    "exclude_from_index": false,
+    "framework": [
+      "Azure ML AutoML"
+    ],
+    "kernelspec": {
+      "display_name": "Python 3.6",
+      "language": "python",
+      "name": "python36"
+    },
+    "language_info": {
+      "codemirror_mode": {
+        "name": "ipython",
+        "version": 3
+      },
+      "file_extension": ".py",
+      "mimetype": "text/x-python",
+      "name": "python",
+      "nbconvert_exporter": "python",
+      "pygments_lexer": "ipython3",
+      "version": "3.6.9"
+    }
+  },
+  "nbformat": 4,
+  "nbformat_minor": 4
+}

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/auto-ml-forecasting-backtest-single-model.yml

@@ -0,0 +1,4 @@
+name: auto-ml-forecasting-backtest-single-model
+dependencies:
+- pip:
+  - azureml-sdk

how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/pipeline_helper.py

@@ -0,0 +1,166 @@
+from typing import Any, Dict, Optional
+
+import os
+
+import azureml.train.automl.runtime._hts.hts_runtime_utilities as hru
+
+from azureml._restclient.jasmine_client import JasmineClient
+from azureml.contrib.automl.pipeline.steps import utilities
+from azureml.core import RunConfiguration
+from azureml.core.compute import ComputeTarget
+from azureml.core.experiment import Experiment
+from azureml.data import LinkTabularOutputDatasetConfig, TabularDataset
+from azureml.pipeline.core import Pipeline, PipelineData, PipelineParameter
+from azureml.pipeline.steps import ParallelRunConfig, ParallelRunStep, PythonScriptStep
+from azureml.train.automl.constants import Scenarios
+from azureml.data.dataset_consumption_config import DatasetConsumptionConfig
+
+
+PROJECT_FOLDER = "assets"
+SETTINGS_FILE = "automl_settings.json"
+
+
+def get_backtest_pipeline(
+    experiment: Experiment,
+    dataset: TabularDataset,
+    process_per_node: int,
+    node_count: int,
+    compute_target: ComputeTarget,
+    automl_settings: Dict[str, Any],
+    step_size: int,
+    step_number: int,
+    model_name: Optional[str] = None,
+    model_uid: Optional[str] = None,
+) -> Pipeline:
+    """
+    :param experiment: The experiment used to run the pipeline.
+    :param dataset: Tabular data set to be used for model training.
+    :param process_per_node: The number of processes per node. Generally it should be the number of cores
+                             on the node divided by two.
+    :param node_count: The number of nodes to be used.
+    :param compute_target: The compute target to be used to run the pipeline.
+    :param model_name: The name of a model to be back tested.
+    :param automl_settings: The dictionary with automl settings.
+    :param step_size: The number of periods to step back in backtesting.
+    :param step_number: The number of backtesting iterations.
+    :param model_uid: The uid to mark models from this run of the experiment.
+    :return: The pipeline to be used for model retraining.
+             **Note:** The output will be uploaded in the pipeline output
+             called 'score'.
+    """
+    jasmine_client = JasmineClient(
+        service_context=experiment.workspace.service_context,
+        experiment_name=experiment.name,
+        experiment_id=experiment.id,
+    )
+    env = jasmine_client.get_curated_environment(
+        scenario=Scenarios.AUTOML,
+        enable_dnn=False,
+        enable_gpu=False,
+        compute=compute_target,
+        compute_sku=experiment.workspace.compute_targets.get(
+            compute_target.name
+        ).vm_size,
+    )
+    data_results = PipelineData(
+        name="results", datastore=None, pipeline_output_name="results"
+    )
+    ############################################################
+    # Split the data set using python script.
+    ############################################################
+    run_config = RunConfiguration()
+    run_config.docker.use_docker = True
+    run_config.environment = env
+
+    split_data = PipelineData(name="split_data_output", datastore=None).as_dataset()
+    split_step = PythonScriptStep(
+        name="split_data_for_backtest",
+        script_name="data_split.py",
+        inputs=[dataset.as_named_input("training_data")],
+        outputs=[split_data],
+        source_directory=PROJECT_FOLDER,
+        arguments=[
+            "--step-size",
+            step_size,
+            "--step-number",
+            step_number,
+            "--time-column-name",
+            automl_settings.get("time_column_name"),
+            "--time-series-id-column-names",
+            automl_settings.get("grain_column_names"),
+            "--output-dir",
+            split_data,
+        ],
+        runconfig=run_config,
+        compute_target=compute_target,
+        allow_reuse=False,
+    )
+    ############################################################
+    # We will do the backtest the parallel run step.
+    ############################################################
+    settings_path = os.path.join(PROJECT_FOLDER, SETTINGS_FILE)
+    hru.dump_object_to_json(automl_settings, settings_path)
+    mini_batch_size = PipelineParameter(name="batch_size_param", default_value=str(1))
+    back_test_config = ParallelRunConfig(
+        source_directory=PROJECT_FOLDER,
+        entry_script="retrain_models.py",
+        mini_batch_size=mini_batch_size,
+        error_threshold=-1,
+        output_action="append_row",
+        append_row_file_name="outputs.txt",
+        compute_target=compute_target,
+        environment=env,
+        process_count_per_node=process_per_node,
+        run_invocation_timeout=3600,
+        node_count=node_count,
+    )
+    forecasts = PipelineData(name="forecasts", datastore=None)
+    if model_name:
+        parallel_step_name = "{}-backtest".format(model_name.replace("_", "-"))
+    else:
+        parallel_step_name = "AutoML-backtest"
+
+    prs_args = [
+        "--target_column_name",
+        automl_settings.get("label_column_name"),
+        "--output-dir",
+        forecasts,
+    ]
+    if model_name is not None:
+        prs_args.append("--model-name")
+        prs_args.append(model_name)
+    if model_uid is not None:
+        prs_args.append("--model-uid")
+        prs_args.append(model_uid)
+    backtest_prs = ParallelRunStep(
+        name=parallel_step_name,
+        parallel_run_config=back_test_config,
+        arguments=prs_args,
+        inputs=[split_data],
+        output=forecasts,
+        allow_reuse=False,
+    )
+    ############################################################
+    # Then we collect the output and return it as scores output.
+    ############################################################
+    collection_step = PythonScriptStep(
+        name="score",
+        script_name="score.py",
+        inputs=[forecasts.as_mount()],
+        outputs=[data_results],
+        source_directory=PROJECT_FOLDER,
+        arguments=[
+            "--forecasts",
+            forecasts,
+            "--output-dir",
+            data_results,
+        ],
+        runconfig=run_config,
+        compute_target=compute_target,
+        allow_reuse=False,
+    )
+    # Build and return the pipeline.
+    return Pipeline(
+        workspace=experiment.workspace,
+        steps=[split_step, backtest_prs, collection_step],
+    )

how-to-use-azureml/automated-machine-learning/forecasting-beer-remote/Beer_no_valid_split_test.csv

@@ -1,20 +0,0 @@
-DATE,grain,BeerProduction
-2017-01-01,grain,9049
-2017-02-01,grain,10458
-2017-03-01,grain,12489
-2017-04-01,grain,11499
-2017-05-01,grain,13553
-2017-06-01,grain,14740
-2017-07-01,grain,11424
-2017-08-01,grain,13412
-2017-09-01,grain,11917
-2017-10-01,grain,12721
-2017-11-01,grain,13272
-2017-12-01,grain,14278
-2018-01-01,grain,9572
-2018-02-01,grain,10423
-2018-03-01,grain,12667
-2018-04-01,grain,11904
-2018-05-01,grain,14120
-2018-06-01,grain,14565
-2018-07-01,grain,12622

how-to-use-azureml/automated-machine-learning/forecasting-beer-remote/Beer_no_valid_split_train.csv

@@ -1,301 +0,0 @@
-DATE,grain,BeerProduction
-1992-01-01,grain,3459
-1992-02-01,grain,3458
-1992-03-01,grain,4002
-1992-04-01,grain,4564
-1992-05-01,grain,4221
-1992-06-01,grain,4529
-1992-07-01,grain,4466
-1992-08-01,grain,4137
-1992-09-01,grain,4126
-1992-10-01,grain,4259
-1992-11-01,grain,4240
-1992-12-01,grain,4936
-1993-01-01,grain,3031
-1993-02-01,grain,3261
-1993-03-01,grain,4160
-1993-04-01,grain,4377
-1993-05-01,grain,4307
-1993-06-01,grain,4696
-1993-07-01,grain,4458
-1993-08-01,grain,4457
-1993-09-01,grain,4364
-1993-10-01,grain,4236
-1993-11-01,grain,4500
-1993-12-01,grain,4974
-1994-01-01,grain,3075
-1994-02-01,grain,3377
-1994-03-01,grain,4443
-1994-04-01,grain,4261
-1994-05-01,grain,4460
-1994-06-01,grain,4985
-1994-07-01,grain,4324
-1994-08-01,grain,4719
-1994-09-01,grain,4374
-1994-10-01,grain,4248
-1994-11-01,grain,4784
-1994-12-01,grain,4971
-1995-01-01,grain,3370
-1995-02-01,grain,3484
-1995-03-01,grain,4269
-1995-04-01,grain,3994
-1995-05-01,grain,4715
-1995-06-01,grain,4974
-1995-07-01,grain,4223
-1995-08-01,grain,5000
-1995-09-01,grain,4235
-1995-10-01,grain,4554
-1995-11-01,grain,4851
-1995-12-01,grain,4826
-1996-01-01,grain,3699
-1996-02-01,grain,3983
-1996-03-01,grain,4262
-1996-04-01,grain,4619
-1996-05-01,grain,5219
-1996-06-01,grain,4836
-1996-07-01,grain,4941
-1996-08-01,grain,5062
-1996-09-01,grain,4365
-1996-10-01,grain,5012
-1996-11-01,grain,4850
-1996-12-01,grain,5097
-1997-01-01,grain,3758
-1997-02-01,grain,3825
-1997-03-01,grain,4454
-1997-04-01,grain,4635
-1997-05-01,grain,5210
-1997-06-01,grain,5057
-1997-07-01,grain,5231
-1997-08-01,grain,5034
-1997-09-01,grain,4970
-1997-10-01,grain,5342
-1997-11-01,grain,4831
-1997-12-01,grain,5965
-1998-01-01,grain,3796
-1998-02-01,grain,4019
-1998-03-01,grain,4898
-1998-04-01,grain,5090
-1998-05-01,grain,5237
-1998-06-01,grain,5447
-1998-07-01,grain,5435
-1998-08-01,grain,5107
-1998-09-01,grain,5515
-1998-10-01,grain,5583
-1998-11-01,grain,5346
-1998-12-01,grain,6286
-1999-01-01,grain,4032
-1999-02-01,grain,4435
-1999-03-01,grain,5479
-1999-04-01,grain,5483
-1999-05-01,grain,5587
-1999-06-01,grain,6176
-1999-07-01,grain,5621
-1999-08-01,grain,5889
-1999-09-01,grain,5828
-1999-10-01,grain,5849
-1999-11-01,grain,6180
-1999-12-01,grain,6771
-2000-01-01,grain,4243
-2000-02-01,grain,4952
-2000-03-01,grain,6008
-2000-04-01,grain,5353
-2000-05-01,grain,6435
-2000-06-01,grain,6673
-2000-07-01,grain,5636
-2000-08-01,grain,6630
-2000-09-01,grain,5887
-2000-10-01,grain,6322
-2000-11-01,grain,6520
-2000-12-01,grain,6678
-2001-01-01,grain,5082
-2001-02-01,grain,5216
-2001-03-01,grain,5893
-2001-04-01,grain,5894
-2001-05-01,grain,6799
-2001-06-01,grain,6667
-2001-07-01,grain,6374
-2001-08-01,grain,6840
-2001-09-01,grain,5575
-2001-10-01,grain,6545
-2001-11-01,grain,6789
-2001-12-01,grain,7180
-2002-01-01,grain,5117
-2002-02-01,grain,5442
-2002-03-01,grain,6337
-2002-04-01,grain,6525
-2002-05-01,grain,7216
-2002-06-01,grain,6761
-2002-07-01,grain,6958
-2002-08-01,grain,7070
-2002-09-01,grain,6148
-2002-10-01,grain,6924
-2002-11-01,grain,6716
-2002-12-01,grain,7975
-2003-01-01,grain,5326
-2003-02-01,grain,5609
-2003-03-01,grain,6414
-2003-04-01,grain,6741
-2003-05-01,grain,7144
-2003-06-01,grain,7133
-2003-07-01,grain,7568
-2003-08-01,grain,7266
-2003-09-01,grain,6634
-2003-10-01,grain,7626
-2003-11-01,grain,6843
-2003-12-01,grain,8540
-2004-01-01,grain,5629
-2004-02-01,grain,5898
-2004-03-01,grain,7045
-2004-04-01,grain,7094
-2004-05-01,grain,7333
-2004-06-01,grain,7918
-2004-07-01,grain,7289
-2004-08-01,grain,7396
-2004-09-01,grain,7259
-2004-10-01,grain,7268
-2004-11-01,grain,7731
-2004-12-01,grain,9058
-2005-01-01,grain,5557
-2005-02-01,grain,6237
-2005-03-01,grain,7723
-2005-04-01,grain,7262
-2005-05-01,grain,8241
-2005-06-01,grain,8757
-2005-07-01,grain,7352
-2005-08-01,grain,8496
-2005-09-01,grain,7741
-2005-10-01,grain,7710
-2005-11-01,grain,8247
-2005-12-01,grain,8902
-2006-01-01,grain,6066
-2006-02-01,grain,6590
-2006-03-01,grain,7923
-2006-04-01,grain,7335
-2006-05-01,grain,8843
-2006-06-01,grain,9327
-2006-07-01,grain,7792
-2006-08-01,grain,9156
-2006-09-01,grain,8037
-2006-10-01,grain,8640
-2006-11-01,grain,9128
-2006-12-01,grain,9545
-2007-01-01,grain,6627
-2007-02-01,grain,6743
-2007-03-01,grain,8195
-2007-04-01,grain,7828
-2007-05-01,grain,9570
-2007-06-01,grain,9484
-2007-07-01,grain,8608
-2007-08-01,grain,9543
-2007-09-01,grain,8123
-2007-10-01,grain,9649
-2007-11-01,grain,9390
-2007-12-01,grain,10065
-2008-01-01,grain,7093
-2008-02-01,grain,7483
-2008-03-01,grain,8365
-2008-04-01,grain,8895
-2008-05-01,grain,9794
-2008-06-01,grain,9977
-2008-07-01,grain,9553
-2008-08-01,grain,9375
-2008-09-01,grain,9225
-2008-10-01,grain,9948
-2008-11-01,grain,8758
-2008-12-01,grain,10839
-2009-01-01,grain,7266
-2009-02-01,grain,7578
-2009-03-01,grain,8688
-2009-04-01,grain,9162
-2009-05-01,grain,9369
-2009-06-01,grain,10167
-2009-07-01,grain,9507
-2009-08-01,grain,8923
-2009-09-01,grain,9272
-2009-10-01,grain,9075
-2009-11-01,grain,8949
-2009-12-01,grain,10843
-2010-01-01,grain,6558
-2010-02-01,grain,7481
-2010-03-01,grain,9475
-2010-04-01,grain,9424
-2010-05-01,grain,9351
-2010-06-01,grain,10552
-2010-07-01,grain,9077
-2010-08-01,grain,9273
-2010-09-01,grain,9420
-2010-10-01,grain,9413
-2010-11-01,grain,9866
-2010-12-01,grain,11455
-2011-01-01,grain,6901
-2011-02-01,grain,8014
-2011-03-01,grain,9832
-2011-04-01,grain,9281
-2011-05-01,grain,9967
-2011-06-01,grain,11344
-2011-07-01,grain,9106
-2011-08-01,grain,10469
-2011-09-01,grain,10085
-2011-10-01,grain,9612
-2011-11-01,grain,10328
-2011-12-01,grain,11483
-2012-01-01,grain,7486
-2012-02-01,grain,8641
-2012-03-01,grain,9709
-2012-04-01,grain,9423
-2012-05-01,grain,11342
-2012-06-01,grain,11274
-2012-07-01,grain,9845
-2012-08-01,grain,11163
-2012-09-01,grain,9532
-2012-10-01,grain,10754
-2012-11-01,grain,10953
-2012-12-01,grain,11922
-2013-01-01,grain,8395
-2013-02-01,grain,8888
-2013-03-01,grain,10110
-2013-04-01,grain,10493
-2013-05-01,grain,12218
-2013-06-01,grain,11385
-2013-07-01,grain,11186
-2013-08-01,grain,11462
-2013-09-01,grain,10494
-2013-10-01,grain,11540
-2013-11-01,grain,11138
-2013-12-01,grain,12709
-2014-01-01,grain,8557
-2014-02-01,grain,9059
-2014-03-01,grain,10055
-2014-04-01,grain,10977
-2014-05-01,grain,11792
-2014-06-01,grain,11904
-2014-07-01,grain,10965
-2014-08-01,grain,10981
-2014-09-01,grain,10828
-2014-10-01,grain,11817
-2014-11-01,grain,10470
-2014-12-01,grain,13310
-2015-01-01,grain,8400
-2015-02-01,grain,9062
-2015-03-01,grain,10722
-2015-04-01,grain,11107
-2015-05-01,grain,11508
-2015-06-01,grain,12904
-2015-07-01,grain,11869
-2015-08-01,grain,11224
-2015-09-01,grain,12022
-2015-10-01,grain,11983
-2015-11-01,grain,11506
-2015-12-01,grain,14183
-2016-01-01,grain,8650
-2016-02-01,grain,10323
-2016-03-01,grain,12110
-2016-04-01,grain,11424
-2016-05-01,grain,12243
-2016-06-01,grain,13686
-2016-07-01,grain,10956
-2016-08-01,grain,12706
-2016-09-01,grain,12279
-2016-10-01,grain,11914
-2016-11-01,grain,13025
-2016-12-01,grain,14431

how-to-use-azureml/automated-machine-learning/forecasting-beer-remote/auto-ml-forecasting-beer-remote.yml

@@ -1,4 +0,0 @@
-name: auto-ml-forecasting-beer-remote
-dependencies:
-- pip:
-  - azureml-sdk

how-to-use-azureml/automated-machine-learning/forecasting-bike-share/auto-ml-forecasting-bike-share.ipynb

@@ -64,15 +64,16 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "import azureml.core\n",
-        "import pandas as pd\n",
-        "import numpy as np\n",
+        "import json\n",
         "import logging\n",
-        "\n",
-        "from azureml.core import Workspace, Experiment, Dataset\n",
-        "from azureml.train.automl import AutoMLConfig\n",
         "from datetime import datetime\n",
-        "from azureml.automl.core.featurization import FeaturizationConfig"
+        "\n",
+        "import azureml.core\n",
+        "import numpy as np\n",
+        "import pandas as pd\n",
+        "from azureml.automl.core.featurization import FeaturizationConfig\n",
+        "from azureml.core import Dataset, Experiment, Workspace\n",
+        "from azureml.train.automl import AutoMLConfig\n"
       ]
     },
     {
@@ -88,7 +89,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -119,7 +120,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Run History Name\"] = experiment_name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "outputDf.T"
       ]
@@ -398,8 +399,8 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "### Retrieve the Best Model\n",
-        "Below we select the best model from all the training iterations using get_output method."
+        "### Retrieve the Best Run details\n",
+        "Below we retrieve the best Run object from among all the runs in the experiment."
       ]
     },
     {
@@ -408,8 +409,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = remote_run.get_output()\n",
-        "fitted_model.steps"
+        "best_run = remote_run.get_best_child()\n",
+        "best_run"
       ]
     },
     {
@@ -418,7 +419,7 @@
       "source": [
         "## Featurization\n",
         "\n",
-        "You can access the engineered feature names generated in time-series featurization. Note that a number of named holiday periods are represented. We recommend that you have at least one year of data when using this feature to ensure that all yearly holidays are captured in the training featurization."
+        "We can look at the engineered feature names generated in time-series featurization via. the JSON file named 'engineered_feature_names.json' under the run outputs. Note that a number of named holiday periods are represented. We recommend that you have at least one year of data when using this feature to ensure that all yearly holidays are captured in the training featurization."
       ]
     },
     {
@@ -427,7 +428,12 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "fitted_model.named_steps[\"timeseriestransformer\"].get_engineered_feature_names()"
+        "# Download the JSON file locally\n",
+        "best_run.download_file(\"outputs/engineered_feature_names.json\", \"engineered_feature_names.json\")\n",
+        "with open(\"engineered_feature_names.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "\n",
+        "records"
       ]
     },
     {
@@ -451,12 +457,16 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "# Get the featurization summary as a list of JSON\n",
-        "featurization_summary = fitted_model.named_steps[\n",
-        "    \"timeseriestransformer\"\n",
-        "].get_featurization_summary()\n",
-        "# View the featurization summary as a pandas dataframe\n",
-        "pd.DataFrame.from_records(featurization_summary)"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "fs = pd.DataFrame.from_records(records)\n",
+        "\n",
+        "# View a summary of the featurization \n",
+        "fs[[\"RawFeatureName\", \"TypeDetected\", \"Dropped\", \"EngineeredFeatureCount\", \"Transformations\"]]"
       ]
     },
     {

how-to-use-azureml/automated-machine-learning/forecasting-energy-demand/auto-ml-forecasting-energy-demand.ipynb

@@ -68,6 +68,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
+        "import json\n",
         "import logging\n",
         "\n",
         "from sklearn.metrics import mean_absolute_error, mean_squared_error, r2_score\n",
@@ -99,7 +100,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -398,8 +399,8 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "## Retrieve the Best Model\n",
-        "Below we select the best model from all the training iterations using get_output method."
+        "### Retrieve the Best Run details\n",
+        "Below we retrieve the best Run object from among all the runs in the experiment."
       ]
     },
     {
@@ -408,8 +409,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = remote_run.get_output()\n",
-        "fitted_model.steps"
+        "best_run = remote_run.get_best_child()\n",
+        "best_run"
       ]
     },
     {
@@ -417,7 +418,7 @@
       "metadata": {},
       "source": [
         "## Featurization\n",
-        "You can access the engineered feature names generated in time-series featurization."
+        "We can look at the engineered feature names generated in time-series featurization via. the JSON file named 'engineered_feature_names.json' under the run outputs. "
       ]
     },
     {
@@ -426,7 +427,12 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "fitted_model.named_steps[\"timeseriestransformer\"].get_engineered_feature_names()"
+        "# Download the JSON file locally\n",
+        "best_run.download_file(\"outputs/engineered_feature_names.json\", \"engineered_feature_names.json\")\n",
+        "with open(\"engineered_feature_names.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "\n",
+        "records"
       ]
     },
     {
@@ -449,12 +455,16 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "# Get the featurization summary as a list of JSON\n",
-        "featurization_summary = fitted_model.named_steps[\n",
-        "    \"timeseriestransformer\"\n",
-        "].get_featurization_summary()\n",
-        "# View the featurization summary as a pandas dataframe\n",
-        "pd.DataFrame.from_records(featurization_summary)"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "fs = pd.DataFrame.from_records(records)\n",
+        "\n",
+        "# View a summary of the featurization \n",
+        "fs[[\"RawFeatureName\", \"TypeDetected\", \"Dropped\", \"EngineeredFeatureCount\", \"Transformations\"]]"
       ]
     },
     {
@@ -641,7 +651,7 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "### Retrieve the Best Model"
+        "### Retrieve the Best Run details"
       ]
     },
     {
@@ -650,7 +660,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run_lags, fitted_model_lags = advanced_remote_run.get_output()"
+        "best_run_lags = remote_run.get_best_child()\n",
+        "best_run_lags"
       ]
     },
     {

how-to-use-azureml/automated-machine-learning/forecasting-forecast-function/auto-ml-forecasting-function.ipynb

@@ -94,7 +94,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

how-to-use-azureml/automated-machine-learning/forecasting-github-dau/auto-ml-forecasting-github-dau.ipynb

@@ -30,7 +30,7 @@
       },
       "source": [
         "# Automated Machine Learning\n",
-        "**Beer Production Forecasting**\n",
+        "**Github DAU Forecasting**\n",
         "\n",
         "## Contents\n",
         "1. [Introduction](#Introduction)\n",
@@ -48,7 +48,7 @@
       },
       "source": [
         "## Introduction\n",
-        "This notebook demonstrates demand forecasting for Beer Production Dataset using AutoML.\n",
+        "This notebook demonstrates demand forecasting for Github Daily Active Users Dataset using AutoML.\n",
         "\n",
         "AutoML highlights here include using Deep Learning forecasts, Arima, Prophet,  Remote Execution and Remote Inferencing, and working with the `forecast` function. Please also look at the additional forecasting notebooks, which document lagging, rolling windows, forecast quantiles, other ways to use the forecast function, and forecaster deployment.\n",
         "\n",
@@ -104,7 +104,7 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "This sample notebook may use features that are not available in previous versions of the Azure ML SDK."
+        "This notebook is compatible with Azure ML SDK version 1.35.0 or later."
       ]
     },
     {
@@ -113,7 +113,6 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -139,7 +138,7 @@
         "ws = Workspace.from_config()\n",
         "\n",
         "# choose a name for the run history container in the workspace\n",
-        "experiment_name = \"beer-remote-cpu\"\n",
+        "experiment_name = \"github-remote-cpu\"\n",
         "\n",
         "experiment = Experiment(ws, experiment_name)\n",
         "\n",
@@ -149,7 +148,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Run History Name\"] = experiment_name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "outputDf.T"
       ]
@@ -180,7 +179,7 @@
         "from azureml.core.compute_target import ComputeTargetException\n",
         "\n",
         "# Choose a name for your CPU cluster\n",
-        "cpu_cluster_name = \"beer-cluster\"\n",
+        "cpu_cluster_name = \"github-cluster\"\n",
         "\n",
         "# Verify that cluster does not exist already\n",
         "try:\n",
@@ -203,7 +202,7 @@
       },
       "source": [
         "## Data\n",
-        "Read Beer demand data from file, and preview data."
+        "Read Github DAU data from file, and preview data."
       ]
     },
     {
@@ -246,21 +245,19 @@
         "plt.tight_layout()\n",
         "\n",
         "plt.subplot(2, 1, 1)\n",
-        "plt.title(\"Beer Production By Year\")\n",
-        "df = pd.read_csv(\n",
-        "    \"Beer_no_valid_split_train.csv\", parse_dates=True, index_col=\"DATE\"\n",
-        ").drop(columns=\"grain\")\n",
+        "plt.title(\"Github Daily Active User By Year\")\n",
+        "df = pd.read_csv(\"github_dau_2011-2018_train.csv\", parse_dates=True, index_col=\"date\")\n",
         "test_df = pd.read_csv(\n",
-        "    \"Beer_no_valid_split_test.csv\", parse_dates=True, index_col=\"DATE\"\n",
-        ").drop(columns=\"grain\")\n",
+        "    \"github_dau_2011-2018_test.csv\", parse_dates=True, index_col=\"date\"\n",
+        ")\n",
         "plt.plot(df)\n",
         "\n",
         "plt.subplot(2, 1, 2)\n",
-        "plt.title(\"Beer Production By Month\")\n",
+        "plt.title(\"Github Daily Active User By Month\")\n",
         "groups = df.groupby(df.index.month)\n",
         "months = concat([DataFrame(x[1].values) for x in groups], axis=1)\n",
         "months = DataFrame(months)\n",
-        "months.columns = range(1, 13)\n",
+        "months.columns = range(1, 49)\n",
         "months.boxplot()\n",
         "\n",
         "plt.show()"
@@ -275,10 +272,10 @@
       },
       "outputs": [],
       "source": [
-        "target_column_name = \"BeerProduction\"\n",
-        "time_column_name = \"DATE\"\n",
+        "target_column_name = \"count\"\n",
+        "time_column_name = \"date\"\n",
         "time_series_id_column_names = []\n",
-        "freq = \"M\"  # Monthly data"
+        "freq = \"D\"  # Daily data"
       ]
     },
     {
@@ -308,19 +305,19 @@
         "datastore = ws.get_default_datastore()\n",
         "datastore.upload_files(\n",
         "    files=[\"./train.csv\"],\n",
-        "    target_path=\"beer-dataset/tabular/\",\n",
+        "    target_path=\"github-dataset/tabular/\",\n",
         "    overwrite=True,\n",
         "    show_progress=True,\n",
         ")\n",
         "datastore.upload_files(\n",
         "    files=[\"./valid.csv\"],\n",
-        "    target_path=\"beer-dataset/tabular/\",\n",
+        "    target_path=\"github-dataset/tabular/\",\n",
         "    overwrite=True,\n",
         "    show_progress=True,\n",
         ")\n",
         "datastore.upload_files(\n",
         "    files=[\"./test.csv\"],\n",
-        "    target_path=\"beer-dataset/tabular/\",\n",
+        "    target_path=\"github-dataset/tabular/\",\n",
         "    overwrite=True,\n",
         "    show_progress=True,\n",
         ")\n",
@@ -328,13 +325,13 @@
         "from azureml.core import Dataset\n",
         "\n",
         "train_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=[(datastore, \"beer-dataset/tabular/train.csv\")]\n",
+        "    path=[(datastore, \"github-dataset/tabular/train.csv\")]\n",
         ")\n",
         "valid_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=[(datastore, \"beer-dataset/tabular/valid.csv\")]\n",
+        "    path=[(datastore, \"github-dataset/tabular/valid.csv\")]\n",
         ")\n",
         "test_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=[(datastore, \"beer-dataset/tabular/test.csv\")]\n",
+        "    path=[(datastore, \"github-dataset/tabular/test.csv\")]\n",
         ")"
       ]
     },
@@ -397,7 +394,7 @@
         "forecasting_parameters = ForecastingParameters(\n",
         "    time_column_name=time_column_name,\n",
         "    forecast_horizon=forecast_horizon,\n",
-        "    freq=\"MS\",  # Set the forecast frequency to be monthly (start of the month)\n",
+        "    freq=\"D\",  # Set the forecast frequency to be daily\n",
         ")\n",
         "\n",
         "# We will disable the enable_early_stopping flag to ensure the DNN model is recommended for demonstration purpose.\n",
@@ -570,7 +567,7 @@
         "from azureml.core import Dataset\n",
         "\n",
         "test_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=[(datastore, \"beer-dataset/tabular/test.csv\")]\n",
+        "    path=[(datastore, \"github-dataset/tabular/test.csv\")]\n",
         ")\n",
         "# preview the first 3 rows of the dataset\n",
         "test_dataset.take(5).to_pandas_dataframe()"
@@ -582,7 +579,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "compute_target = ws.compute_targets[\"beer-cluster\"]\n",
+        "compute_target = ws.compute_targets[\"github-cluster\"]\n",
         "test_experiment = Experiment(ws, experiment_name + \"_test\")"
       ]
     },

how-to-use-azureml/automated-machine-learning/forecasting-github-dau/auto-ml-forecasting-github-dau.yml

@@ -0,0 +1,4 @@
+name: auto-ml-forecasting-github-dau
+dependencies:
+- pip:
+  - azureml-sdk

how-to-use-azureml/automated-machine-learning/forecasting-github-dau/github_dau_2011-2018_test.csv

@@ -0,0 +1,455 @@
+date,count,day_of_week,month_of_year,holiday
+2017-06-04,104663,6.0,5.0,0.0
+2017-06-05,155824,0.0,5.0,0.0
+2017-06-06,164908,1.0,5.0,0.0
+2017-06-07,170309,2.0,5.0,0.0
+2017-06-08,164256,3.0,5.0,0.0
+2017-06-09,153406,4.0,5.0,0.0
+2017-06-10,97024,5.0,5.0,0.0
+2017-06-11,103442,6.0,5.0,0.0
+2017-06-12,160768,0.0,5.0,0.0
+2017-06-13,166288,1.0,5.0,0.0
+2017-06-14,163819,2.0,5.0,0.0
+2017-06-15,157593,3.0,5.0,0.0
+2017-06-16,149259,4.0,5.0,0.0
+2017-06-17,95579,5.0,5.0,0.0
+2017-06-18,98723,6.0,5.0,0.0
+2017-06-19,159076,0.0,5.0,0.0
+2017-06-20,163340,1.0,5.0,0.0
+2017-06-21,163344,2.0,5.0,0.0
+2017-06-22,159528,3.0,5.0,0.0
+2017-06-23,146563,4.0,5.0,0.0
+2017-06-24,92631,5.0,5.0,0.0
+2017-06-25,96549,6.0,5.0,0.0
+2017-06-26,153249,0.0,5.0,0.0
+2017-06-27,160357,1.0,5.0,0.0
+2017-06-28,159941,2.0,5.0,0.0
+2017-06-29,156781,3.0,5.0,0.0
+2017-06-30,144709,4.0,5.0,0.0
+2017-07-01,89101,5.0,6.0,0.0
+2017-07-02,93046,6.0,6.0,0.0
+2017-07-03,144113,0.0,6.0,0.0
+2017-07-04,143061,1.0,6.0,1.0
+2017-07-05,154603,2.0,6.0,0.0
+2017-07-06,157200,3.0,6.0,0.0
+2017-07-07,147213,4.0,6.0,0.0
+2017-07-08,92348,5.0,6.0,0.0
+2017-07-09,97018,6.0,6.0,0.0
+2017-07-10,157192,0.0,6.0,0.0
+2017-07-11,161819,1.0,6.0,0.0
+2017-07-12,161998,2.0,6.0,0.0
+2017-07-13,160280,3.0,6.0,0.0
+2017-07-14,146818,4.0,6.0,0.0
+2017-07-15,93041,5.0,6.0,0.0
+2017-07-16,97505,6.0,6.0,0.0
+2017-07-17,156167,0.0,6.0,0.0
+2017-07-18,162855,1.0,6.0,0.0
+2017-07-19,162519,2.0,6.0,0.0
+2017-07-20,159941,3.0,6.0,0.0
+2017-07-21,148460,4.0,6.0,0.0
+2017-07-22,93431,5.0,6.0,0.0
+2017-07-23,98553,6.0,6.0,0.0
+2017-07-24,156202,0.0,6.0,0.0
+2017-07-25,162503,1.0,6.0,0.0
+2017-07-26,158479,2.0,6.0,0.0
+2017-07-27,158192,3.0,6.0,0.0
+2017-07-28,147108,4.0,6.0,0.0
+2017-07-29,93799,5.0,6.0,0.0
+2017-07-30,97920,6.0,6.0,0.0
+2017-07-31,152197,0.0,6.0,0.0
+2017-08-01,158477,1.0,7.0,0.0
+2017-08-02,159089,2.0,7.0,0.0
+2017-08-03,157182,3.0,7.0,0.0
+2017-08-04,146345,4.0,7.0,0.0
+2017-08-05,92534,5.0,7.0,0.0
+2017-08-06,97128,6.0,7.0,0.0
+2017-08-07,151359,0.0,7.0,0.0
+2017-08-08,159895,1.0,7.0,0.0
+2017-08-09,158329,2.0,7.0,0.0
+2017-08-10,155468,3.0,7.0,0.0
+2017-08-11,144914,4.0,7.0,0.0
+2017-08-12,92258,5.0,7.0,0.0
+2017-08-13,95933,6.0,7.0,0.0
+2017-08-14,147706,0.0,7.0,0.0
+2017-08-15,151115,1.0,7.0,0.0
+2017-08-16,157640,2.0,7.0,0.0
+2017-08-17,156600,3.0,7.0,0.0
+2017-08-18,146980,4.0,7.0,0.0
+2017-08-19,94592,5.0,7.0,0.0
+2017-08-20,99320,6.0,7.0,0.0
+2017-08-21,145727,0.0,7.0,0.0
+2017-08-22,160260,1.0,7.0,0.0
+2017-08-23,160440,2.0,7.0,0.0
+2017-08-24,157830,3.0,7.0,0.0
+2017-08-25,145822,4.0,7.0,0.0
+2017-08-26,94706,5.0,7.0,0.0
+2017-08-27,99047,6.0,7.0,0.0
+2017-08-28,152112,0.0,7.0,0.0
+2017-08-29,162440,1.0,7.0,0.0
+2017-08-30,162902,2.0,7.0,0.0
+2017-08-31,159498,3.0,7.0,0.0
+2017-09-01,145689,4.0,8.0,0.0
+2017-09-02,93589,5.0,8.0,0.0
+2017-09-03,100058,6.0,8.0,0.0
+2017-09-04,140865,0.0,8.0,1.0
+2017-09-05,165715,1.0,8.0,0.0
+2017-09-06,167463,2.0,8.0,0.0
+2017-09-07,164811,3.0,8.0,0.0
+2017-09-08,156157,4.0,8.0,0.0
+2017-09-09,101358,5.0,8.0,0.0
+2017-09-10,107915,6.0,8.0,0.0
+2017-09-11,167845,0.0,8.0,0.0
+2017-09-12,172756,1.0,8.0,0.0
+2017-09-13,172851,2.0,8.0,0.0
+2017-09-14,171675,3.0,8.0,0.0
+2017-09-15,159266,4.0,8.0,0.0
+2017-09-16,103547,5.0,8.0,0.0
+2017-09-17,110964,6.0,8.0,0.0
+2017-09-18,170976,0.0,8.0,0.0
+2017-09-19,177864,1.0,8.0,0.0
+2017-09-20,173567,2.0,8.0,0.0
+2017-09-21,172017,3.0,8.0,0.0
+2017-09-22,161357,4.0,8.0,0.0
+2017-09-23,104681,5.0,8.0,0.0
+2017-09-24,111711,6.0,8.0,0.0
+2017-09-25,173517,0.0,8.0,0.0
+2017-09-26,180049,1.0,8.0,0.0
+2017-09-27,178307,2.0,8.0,0.0
+2017-09-28,174157,3.0,8.0,0.0
+2017-09-29,161707,4.0,8.0,0.0
+2017-09-30,110536,5.0,8.0,0.0
+2017-10-01,106505,6.0,9.0,0.0
+2017-10-02,157565,0.0,9.0,0.0
+2017-10-03,164764,1.0,9.0,0.0
+2017-10-04,163383,2.0,9.0,0.0
+2017-10-05,162847,3.0,9.0,0.0
+2017-10-06,153575,4.0,9.0,0.0
+2017-10-07,107472,5.0,9.0,0.0
+2017-10-08,116127,6.0,9.0,0.0
+2017-10-09,174457,0.0,9.0,1.0
+2017-10-10,185217,1.0,9.0,0.0
+2017-10-11,185120,2.0,9.0,0.0
+2017-10-12,180844,3.0,9.0,0.0
+2017-10-13,170178,4.0,9.0,0.0
+2017-10-14,112754,5.0,9.0,0.0
+2017-10-15,121251,6.0,9.0,0.0
+2017-10-16,183906,0.0,9.0,0.0
+2017-10-17,188945,1.0,9.0,0.0
+2017-10-18,187297,2.0,9.0,0.0
+2017-10-19,183867,3.0,9.0,0.0
+2017-10-20,173021,4.0,9.0,0.0
+2017-10-21,115851,5.0,9.0,0.0
+2017-10-22,126088,6.0,9.0,0.0
+2017-10-23,189452,0.0,9.0,0.0
+2017-10-24,194412,1.0,9.0,0.0
+2017-10-25,192293,2.0,9.0,0.0
+2017-10-26,190163,3.0,9.0,0.0
+2017-10-27,177053,4.0,9.0,0.0
+2017-10-28,114934,5.0,9.0,0.0
+2017-10-29,125289,6.0,9.0,0.0
+2017-10-30,189245,0.0,9.0,0.0
+2017-10-31,191480,1.0,9.0,0.0
+2017-11-01,182281,2.0,10.0,0.0
+2017-11-02,186351,3.0,10.0,0.0
+2017-11-03,175422,4.0,10.0,0.0
+2017-11-04,118160,5.0,10.0,0.0
+2017-11-05,127602,6.0,10.0,0.0
+2017-11-06,191067,0.0,10.0,0.0
+2017-11-07,197083,1.0,10.0,0.0
+2017-11-08,194333,2.0,10.0,0.0
+2017-11-09,193914,3.0,10.0,0.0
+2017-11-10,179933,4.0,10.0,1.0
+2017-11-11,121346,5.0,10.0,0.0
+2017-11-12,131900,6.0,10.0,0.0
+2017-11-13,196969,0.0,10.0,0.0
+2017-11-14,201949,1.0,10.0,0.0
+2017-11-15,198424,2.0,10.0,0.0
+2017-11-16,196902,3.0,10.0,0.0
+2017-11-17,183893,4.0,10.0,0.0
+2017-11-18,122767,5.0,10.0,0.0
+2017-11-19,130890,6.0,10.0,0.0
+2017-11-20,194515,0.0,10.0,0.0
+2017-11-21,198601,1.0,10.0,0.0
+2017-11-22,191041,2.0,10.0,0.0
+2017-11-23,170321,3.0,10.0,1.0
+2017-11-24,155623,4.0,10.0,0.0
+2017-11-25,115759,5.0,10.0,0.0
+2017-11-26,128771,6.0,10.0,0.0
+2017-11-27,199419,0.0,10.0,0.0
+2017-11-28,207253,1.0,10.0,0.0
+2017-11-29,205406,2.0,10.0,0.0
+2017-11-30,200674,3.0,10.0,0.0
+2017-12-01,187017,4.0,11.0,0.0
+2017-12-02,129735,5.0,11.0,0.0
+2017-12-03,139120,6.0,11.0,0.0
+2017-12-04,205505,0.0,11.0,0.0
+2017-12-05,208218,1.0,11.0,0.0
+2017-12-06,202480,2.0,11.0,0.0
+2017-12-07,197822,3.0,11.0,0.0
+2017-12-08,180686,4.0,11.0,0.0
+2017-12-09,123667,5.0,11.0,0.0
+2017-12-10,130987,6.0,11.0,0.0
+2017-12-11,193901,0.0,11.0,0.0
+2017-12-12,194997,1.0,11.0,0.0
+2017-12-13,192063,2.0,11.0,0.0
+2017-12-14,186496,3.0,11.0,0.0
+2017-12-15,170812,4.0,11.0,0.0
+2017-12-16,110474,5.0,11.0,0.0
+2017-12-17,118165,6.0,11.0,0.0
+2017-12-18,176843,0.0,11.0,0.0
+2017-12-19,179550,1.0,11.0,0.0
+2017-12-20,173506,2.0,11.0,0.0
+2017-12-21,165910,3.0,11.0,0.0
+2017-12-22,145886,4.0,11.0,0.0
+2017-12-23,95246,5.0,11.0,0.0
+2017-12-24,88781,6.0,11.0,0.0
+2017-12-25,98189,0.0,11.0,1.0
+2017-12-26,121383,1.0,11.0,0.0
+2017-12-27,135300,2.0,11.0,0.0
+2017-12-28,136827,3.0,11.0,0.0
+2017-12-29,127700,4.0,11.0,0.0
+2017-12-30,93014,5.0,11.0,0.0
+2017-12-31,82878,6.0,11.0,0.0
+2018-01-01,86419,0.0,0.0,1.0
+2018-01-02,147428,1.0,0.0,0.0
+2018-01-03,162193,2.0,0.0,0.0
+2018-01-04,163784,3.0,0.0,0.0
+2018-01-05,158606,4.0,0.0,0.0
+2018-01-06,113467,5.0,0.0,0.0
+2018-01-07,118313,6.0,0.0,0.0
+2018-01-08,175623,0.0,0.0,0.0
+2018-01-09,183880,1.0,0.0,0.0
+2018-01-10,183945,2.0,0.0,0.0
+2018-01-11,181769,3.0,0.0,0.0
+2018-01-12,170552,4.0,0.0,0.0
+2018-01-13,115707,5.0,0.0,0.0
+2018-01-14,121191,6.0,0.0,0.0
+2018-01-15,176127,0.0,0.0,1.0
+2018-01-16,188032,1.0,0.0,0.0
+2018-01-17,189871,2.0,0.0,0.0
+2018-01-18,189348,3.0,0.0,0.0
+2018-01-19,177456,4.0,0.0,0.0
+2018-01-20,123321,5.0,0.0,0.0
+2018-01-21,128306,6.0,0.0,0.0
+2018-01-22,186132,0.0,0.0,0.0
+2018-01-23,197618,1.0,0.0,0.0
+2018-01-24,196402,2.0,0.0,0.0
+2018-01-25,192722,3.0,0.0,0.0
+2018-01-26,179415,4.0,0.0,0.0
+2018-01-27,125769,5.0,0.0,0.0
+2018-01-28,133306,6.0,0.0,0.0
+2018-01-29,194151,0.0,0.0,0.0
+2018-01-30,198680,1.0,0.0,0.0
+2018-01-31,198652,2.0,0.0,0.0
+2018-02-01,195472,3.0,1.0,0.0
+2018-02-02,183173,4.0,1.0,0.0
+2018-02-03,124276,5.0,1.0,0.0
+2018-02-04,129054,6.0,1.0,0.0
+2018-02-05,190024,0.0,1.0,0.0
+2018-02-06,198658,1.0,1.0,0.0
+2018-02-07,198272,2.0,1.0,0.0
+2018-02-08,195339,3.0,1.0,0.0
+2018-02-09,183086,4.0,1.0,0.0
+2018-02-10,122536,5.0,1.0,0.0
+2018-02-11,133033,6.0,1.0,0.0
+2018-02-12,185386,0.0,1.0,0.0
+2018-02-13,184789,1.0,1.0,0.0
+2018-02-14,176089,2.0,1.0,0.0
+2018-02-15,171317,3.0,1.0,0.0
+2018-02-16,162693,4.0,1.0,0.0
+2018-02-17,116342,5.0,1.0,0.0
+2018-02-18,122466,6.0,1.0,0.0
+2018-02-19,172364,0.0,1.0,1.0
+2018-02-20,185896,1.0,1.0,0.0
+2018-02-21,188166,2.0,1.0,0.0
+2018-02-22,189427,3.0,1.0,0.0
+2018-02-23,178732,4.0,1.0,0.0
+2018-02-24,132664,5.0,1.0,0.0
+2018-02-25,134008,6.0,1.0,0.0
+2018-02-26,200075,0.0,1.0,0.0
+2018-02-27,207996,1.0,1.0,0.0
+2018-02-28,204416,2.0,1.0,0.0
+2018-03-01,201320,3.0,2.0,0.0
+2018-03-02,188205,4.0,2.0,0.0
+2018-03-03,131162,5.0,2.0,0.0
+2018-03-04,138320,6.0,2.0,0.0
+2018-03-05,207326,0.0,2.0,0.0
+2018-03-06,212462,1.0,2.0,0.0
+2018-03-07,209357,2.0,2.0,0.0
+2018-03-08,194876,3.0,2.0,0.0
+2018-03-09,193761,4.0,2.0,0.0
+2018-03-10,133449,5.0,2.0,0.0
+2018-03-11,142258,6.0,2.0,0.0
+2018-03-12,208753,0.0,2.0,0.0
+2018-03-13,210602,1.0,2.0,0.0
+2018-03-14,214236,2.0,2.0,0.0
+2018-03-15,210761,3.0,2.0,0.0
+2018-03-16,196619,4.0,2.0,0.0
+2018-03-17,133056,5.0,2.0,0.0
+2018-03-18,141335,6.0,2.0,0.0
+2018-03-19,211580,0.0,2.0,0.0
+2018-03-20,219051,1.0,2.0,0.0
+2018-03-21,215435,2.0,2.0,0.0
+2018-03-22,211961,3.0,2.0,0.0
+2018-03-23,196009,4.0,2.0,0.0
+2018-03-24,132390,5.0,2.0,0.0
+2018-03-25,140021,6.0,2.0,0.0
+2018-03-26,205273,0.0,2.0,0.0
+2018-03-27,212686,1.0,2.0,0.0
+2018-03-28,210683,2.0,2.0,0.0
+2018-03-29,189044,3.0,2.0,0.0
+2018-03-30,170256,4.0,2.0,0.0
+2018-03-31,125999,5.0,2.0,0.0
+2018-04-01,126749,6.0,3.0,0.0
+2018-04-02,186546,0.0,3.0,0.0
+2018-04-03,207905,1.0,3.0,0.0
+2018-04-04,201528,2.0,3.0,0.0
+2018-04-05,188580,3.0,3.0,0.0
+2018-04-06,173714,4.0,3.0,0.0
+2018-04-07,125723,5.0,3.0,0.0
+2018-04-08,142545,6.0,3.0,0.0
+2018-04-09,204767,0.0,3.0,0.0
+2018-04-10,212048,1.0,3.0,0.0
+2018-04-11,210517,2.0,3.0,0.0
+2018-04-12,206924,3.0,3.0,0.0
+2018-04-13,191679,4.0,3.0,0.0
+2018-04-14,126394,5.0,3.0,0.0
+2018-04-15,137279,6.0,3.0,0.0
+2018-04-16,208085,0.0,3.0,0.0
+2018-04-17,213273,1.0,3.0,0.0
+2018-04-18,211580,2.0,3.0,0.0
+2018-04-19,206037,3.0,3.0,0.0
+2018-04-20,191211,4.0,3.0,0.0
+2018-04-21,125564,5.0,3.0,0.0
+2018-04-22,136469,6.0,3.0,0.0
+2018-04-23,206288,0.0,3.0,0.0
+2018-04-24,212115,1.0,3.0,0.0
+2018-04-25,207948,2.0,3.0,0.0
+2018-04-26,205759,3.0,3.0,0.0
+2018-04-27,181330,4.0,3.0,0.0
+2018-04-28,130046,5.0,3.0,0.0
+2018-04-29,120802,6.0,3.0,0.0
+2018-04-30,170390,0.0,3.0,0.0
+2018-05-01,169054,1.0,4.0,0.0
+2018-05-02,197891,2.0,4.0,0.0
+2018-05-03,199820,3.0,4.0,0.0
+2018-05-04,186783,4.0,4.0,0.0
+2018-05-05,124420,5.0,4.0,0.0
+2018-05-06,130666,6.0,4.0,0.0
+2018-05-07,196014,0.0,4.0,0.0
+2018-05-08,203058,1.0,4.0,0.0
+2018-05-09,198582,2.0,4.0,0.0
+2018-05-10,191321,3.0,4.0,0.0
+2018-05-11,183639,4.0,4.0,0.0
+2018-05-12,122023,5.0,4.0,0.0
+2018-05-13,128775,6.0,4.0,0.0
+2018-05-14,199104,0.0,4.0,0.0
+2018-05-15,200658,1.0,4.0,0.0
+2018-05-16,201541,2.0,4.0,0.0
+2018-05-17,196886,3.0,4.0,0.0
+2018-05-18,188597,4.0,4.0,0.0
+2018-05-19,121392,5.0,4.0,0.0
+2018-05-20,126981,6.0,4.0,0.0
+2018-05-21,189291,0.0,4.0,0.0
+2018-05-22,203038,1.0,4.0,0.0
+2018-05-23,205330,2.0,4.0,0.0
+2018-05-24,199208,3.0,4.0,0.0
+2018-05-25,187768,4.0,4.0,0.0
+2018-05-26,117635,5.0,4.0,0.0
+2018-05-27,124352,6.0,4.0,0.0
+2018-05-28,180398,0.0,4.0,1.0
+2018-05-29,194170,1.0,4.0,0.0
+2018-05-30,200281,2.0,4.0,0.0
+2018-05-31,197244,3.0,4.0,0.0
+2018-06-01,184037,4.0,5.0,0.0
+2018-06-02,121135,5.0,5.0,0.0
+2018-06-03,129389,6.0,5.0,0.0
+2018-06-04,200331,0.0,5.0,0.0
+2018-06-05,207735,1.0,5.0,0.0
+2018-06-06,203354,2.0,5.0,0.0
+2018-06-07,200520,3.0,5.0,0.0
+2018-06-08,182038,4.0,5.0,0.0
+2018-06-09,120164,5.0,5.0,0.0
+2018-06-10,125256,6.0,5.0,0.0
+2018-06-11,194786,0.0,5.0,0.0
+2018-06-12,200815,1.0,5.0,0.0
+2018-06-13,197740,2.0,5.0,0.0
+2018-06-14,192294,3.0,5.0,0.0
+2018-06-15,173587,4.0,5.0,0.0
+2018-06-16,105955,5.0,5.0,0.0
+2018-06-17,110780,6.0,5.0,0.0
+2018-06-18,174582,0.0,5.0,0.0
+2018-06-19,193310,1.0,5.0,0.0
+2018-06-20,193062,2.0,5.0,0.0
+2018-06-21,187986,3.0,5.0,0.0
+2018-06-22,173606,4.0,5.0,0.0
+2018-06-23,111795,5.0,5.0,0.0
+2018-06-24,116134,6.0,5.0,0.0
+2018-06-25,185919,0.0,5.0,0.0
+2018-06-26,193142,1.0,5.0,0.0
+2018-06-27,188114,2.0,5.0,0.0
+2018-06-28,183737,3.0,5.0,0.0
+2018-06-29,171496,4.0,5.0,0.0
+2018-06-30,107210,5.0,5.0,0.0
+2018-07-01,111053,6.0,6.0,0.0
+2018-07-02,176198,0.0,6.0,0.0
+2018-07-03,184040,1.0,6.0,0.0
+2018-07-04,169783,2.0,6.0,1.0
+2018-07-05,177996,3.0,6.0,0.0
+2018-07-06,167378,4.0,6.0,0.0
+2018-07-07,106401,5.0,6.0,0.0
+2018-07-08,112327,6.0,6.0,0.0
+2018-07-09,182835,0.0,6.0,0.0
+2018-07-10,187694,1.0,6.0,0.0
+2018-07-11,185762,2.0,6.0,0.0
+2018-07-12,184099,3.0,6.0,0.0
+2018-07-13,170860,4.0,6.0,0.0
+2018-07-14,106799,5.0,6.0,0.0
+2018-07-15,108475,6.0,6.0,0.0
+2018-07-16,175704,0.0,6.0,0.0
+2018-07-17,183596,1.0,6.0,0.0
+2018-07-18,179897,2.0,6.0,0.0
+2018-07-19,183373,3.0,6.0,0.0
+2018-07-20,169626,4.0,6.0,0.0
+2018-07-21,106785,5.0,6.0,0.0
+2018-07-22,112387,6.0,6.0,0.0
+2018-07-23,180572,0.0,6.0,0.0
+2018-07-24,186943,1.0,6.0,0.0
+2018-07-25,185744,2.0,6.0,0.0
+2018-07-26,183117,3.0,6.0,0.0
+2018-07-27,168526,4.0,6.0,0.0
+2018-07-28,105936,5.0,6.0,0.0
+2018-07-29,111708,6.0,6.0,0.0
+2018-07-30,179950,0.0,6.0,0.0
+2018-07-31,185930,1.0,6.0,0.0
+2018-08-01,183366,2.0,7.0,0.0
+2018-08-02,182412,3.0,7.0,0.0
+2018-08-03,173429,4.0,7.0,0.0
+2018-08-04,106108,5.0,7.0,0.0
+2018-08-05,110059,6.0,7.0,0.0
+2018-08-06,178355,0.0,7.0,0.0
+2018-08-07,185518,1.0,7.0,0.0
+2018-08-08,183204,2.0,7.0,0.0
+2018-08-09,181276,3.0,7.0,0.0
+2018-08-10,168297,4.0,7.0,0.0
+2018-08-11,106488,5.0,7.0,0.0
+2018-08-12,111786,6.0,7.0,0.0
+2018-08-13,178620,0.0,7.0,0.0
+2018-08-14,181922,1.0,7.0,0.0
+2018-08-15,172198,2.0,7.0,0.0
+2018-08-16,177367,3.0,7.0,0.0
+2018-08-17,166550,4.0,7.0,0.0
+2018-08-18,107011,5.0,7.0,0.0
+2018-08-19,112299,6.0,7.0,0.0
+2018-08-20,176718,0.0,7.0,0.0
+2018-08-21,182562,1.0,7.0,0.0
+2018-08-22,181484,2.0,7.0,0.0
+2018-08-23,180317,3.0,7.0,0.0
+2018-08-24,170197,4.0,7.0,0.0
+2018-08-25,109383,5.0,7.0,0.0
+2018-08-26,113373,6.0,7.0,0.0
+2018-08-27,180142,0.0,7.0,0.0
+2018-08-28,191628,1.0,7.0,0.0
+2018-08-29,191149,2.0,7.0,0.0
+2018-08-30,187503,3.0,7.0,0.0
+2018-08-31,172280,4.0,7.0,0.0

how-to-use-azureml/automated-machine-learning/forecasting-github-dau/helper.py

@@ -105,13 +105,8 @@ def run_inference(
     train_run.download_file(
         "outputs/{}".format(model_base_name), "inference/{}".format(model_base_name)
     )
-    train_run.download_file("outputs/conda_env_v_1_0_0.yml", "inference/condafile.yml")
 
-    inference_env = Environment("myenv")
-    inference_env.docker.enabled = True
-    inference_env.python.conda_dependencies = CondaDependencies(
-        conda_dependencies_file_path="inference/condafile.yml"
-    )
+    inference_env = train_run.get_environment()
 
     est = Estimator(
         source_directory=script_folder,

how-to-use-azureml/automated-machine-learning/forecasting-hierarchical-timeseries/auto-ml-forecasting-hierarchical-timeseries.ipynb

@@ -78,7 +78,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Default datastore name\"] = dstore.name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "outputDf.T"
       ]
@@ -150,37 +150,13 @@
         "datastore"
       ]
     },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {
-        "gather": {
-          "logged": 1613005886349
-        },
-        "jupyter": {
-          "outputs_hidden": false,
-          "source_hidden": false
-        },
-        "nteract": {
-          "transient": {
-            "deleting": false
-          }
-        }
-      },
-      "outputs": [],
-      "source": [
-        "datastore.upload(\n",
-        "    src_dir=\"./Data/\", target_path=datastore_path, overwrite=True, show_progress=True\n",
-        ")"
-      ]
-    },
     {
       "cell_type": "markdown",
       "metadata": {},
       "source": [
         "### Create the TabularDatasets \n",
         "\n",
-        "Datasets in Azure Machine Learning are references to specific data in a Datastore. The data can be retrieved as a [TabularDatasets](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.data.tabulardataset?view=azure-ml-py)."
+        "Datasets in Azure Machine Learning are references to specific data in a Datastore. The data can be retrieved as a [TabularDatasets](https://docs.microsoft.com/en-us/python/api/azureml-core/azureml.data.tabulardataset?view=azure-ml-py). We will read in the data as a pandas DataFrame, upload to the data store and register them to your Workspace using ```register_pandas_dataframe``` so they can be called as an input into the training pipeline. We will use the inference dataset as part of the forecasting pipeline. The step need only be completed once."
       ]
     },
     {
@@ -193,34 +169,20 @@
       },
       "outputs": [],
       "source": [
-        "from azureml.core.dataset import Dataset\n",
+        "from azureml.data.dataset_factory import TabularDatasetFactory\n",
         "\n",
-        "train_ds = Dataset.Tabular.from_delimited_files(\n",
-        "    path=datastore.path(\"hts-sample/hts-sample-train.csv\"), validate=False\n",
+        "registered_train = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    pd.read_csv(\"Data/hts-sample-train.csv\"),\n",
+        "    target=(datastore, \"hts-sample\"),\n",
+        "    name=\"hts-sales-train\",\n",
         ")\n",
-        "inference_ds = Dataset.Tabular.from_delimited_files(\n",
-        "    path=datastore.path(\"hts-sample/hts-sample-test.csv\"), validate=False\n",
+        "registered_inference = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    pd.read_csv(\"Data/hts-sample-test.csv\"),\n",
+        "    target=(datastore, \"hts-sample\"),\n",
+        "    name=\"hts-sales-test\",\n",
         ")"
       ]
     },
-    {
-      "cell_type": "markdown",
-      "metadata": {},
-      "source": [
-        "### Register the TabularDatasets to the Workspace \n",
-        "Finally, register the dataset to your Workspace so it can be called as an input into the training pipeline in the next notebook. We will use the inference dataset as part of the forecasting pipeline. The step need only be completed once."
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "registered_train = train_ds.register(ws, \"hts-sales-train\")\n",
-        "registered_inference = inference_ds.register(ws, \"hts-sales-test\")"
-      ]
-    },
     {
       "cell_type": "markdown",
       "metadata": {},

how-to-use-azureml/automated-machine-learning/forecasting-many-models/auto-ml-forecasting-many-models.ipynb

@@ -30,7 +30,7 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "For this notebook we are using a synthetic dataset portraying sales data to predict the the quantity of a vartiety of product skus across several states, stores, and product categories.\n",
+        "For this notebook we are using a synthetic dataset portraying sales data to predict the quantity of a vartiety of product SKUs across several states, stores, and product categories.\n",
         "\n",
         "**NOTE: There are limits on how many runs we can do in parallel per workspace, and we currently recommend to set the parallelism to maximum of 320 runs per experiment per workspace. If users want to have more parallelism and increase this limit they might encounter Too Many Requests errors (HTTP 429).**"
       ]
@@ -78,7 +78,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Default datastore name\"] = dstore.name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "outputDf.T"
       ]
@@ -234,11 +234,14 @@
         "input_ds_small = Dataset.Tabular.from_delimited_files(\n",
         "    path=oj_datastore.path(ds_name_small + \"/\"), validate=False\n",
         ")\n",
+        "# Drop the columns 'Revenue' as this column contains leak feature.\n",
+        "input_ds_small = input_ds_small.drop_columns(columns=[\"Revenue\"])\n",
         "\n",
         "inference_name_small = \"oj-inference-small-tabular\"\n",
         "inference_ds_small = Dataset.Tabular.from_delimited_files(\n",
         "    path=oj_datastore.path(inference_name_small + \"/\"), validate=False\n",
-        ")"
+        ")\n",
+        "inference_ds_small = inference_ds_small.drop_columns(columns=[\"Revenue\"])"
       ]
     },
     {
@@ -308,7 +311,7 @@
       "source": [
         "### Set up training parameters\n",
         "\n",
-        "This dictionary defines the AutoML and many models settings. For this forecasting task we need to define several settings inncluding the name of the time column, the maximum forecast horizon, and the partition column name definition.\n",
+        "This dictionary defines the AutoML and many models settings. For this forecasting task we need to define several settings including the name of the time column, the maximum forecast horizon, and the partition column name definition.\n",
         "\n",
         "| Property                           | Description|\n",
         "| :---------------                   | :------------------- |\n",
@@ -354,7 +357,6 @@
         "    \"label_column_name\": \"Quantity\",\n",
         "    \"n_cross_validations\": 3,\n",
         "    \"time_column_name\": \"WeekStarting\",\n",
-        "    \"drop_column_names\": \"Revenue\",\n",
         "    \"max_horizon\": 6,\n",
         "    \"grain_column_names\": partition_column_names,\n",
         "    \"track_child_runs\": False,\n",
@@ -554,12 +556,12 @@
         "| :---------------                   | :------------------- |\n",
         "| **experiment**                     | The experiment used for inference run. |\n",
         "| **inference_data**                 | The data to use for inferencing. It should be the same schema as used for training.\n",
-        "| **compute_target** The compute target that runs the inference pipeline.|\n",
+        "| **compute_target**                 | The compute target that runs the inference pipeline.|\n",
         "| **node_count**                     | The number of compute nodes to be used for running the user script. We recommend to start with the number of cores per node (varies by compute sku). |\n",
-        "| **process_count_per_node** The number of processes per node.\n",
-        "| **train_run_id**                   | \\[Optional] The run id of the hierarchy training, by default it is the latest successful training many model run in the experiment. |\n",
-        "| **train_experiment_name**          | \\[Optional] The train experiment that contains the train pipeline. This one is only needed when the train pipeline is not in the same experiement as the inference pipeline. |\n",
-        "| **process_count_per_node**         | \\[Optional] The number of processes per node, by default it's 4. |"
+        "| **process_count_per_node**         | The number of processes per node.\n",
+        "| **train_run_id**                   | \\[Optional\\] The run id of the hierarchy training, by default it is the latest successful training many model run in the experiment. |\n",
+        "| **train_experiment_name**          | \\[Optional\\] The train experiment that contains the train pipeline. This one is only needed when the train pipeline is not in the same experiement as the inference pipeline. |\n",
+        "| **process_count_per_node**         | \\[Optional\\] The number of processes per node, by default it's 4. |"
       ]
     },
     {
@@ -649,7 +651,6 @@
         "    \"Quantity\",\n",
         "    \"Advert\",\n",
         "    \"Price\",\n",
-        "    \"Revenue\",\n",
         "    \"Predicted\",\n",
         "]\n",
         "print(\n",

how-to-use-azureml/automated-machine-learning/forecasting-orange-juice-sales/auto-ml-forecasting-orange-juice-sales.ipynb

@@ -58,14 +58,15 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "import azureml.core\n",
-        "import pandas as pd\n",
+        "import json\n",
         "import logging\n",
         "\n",
-        "from azureml.core.workspace import Workspace\n",
+        "import azureml.core\n",
+        "import pandas as pd\n",
+        "from azureml.automl.core.featurization import FeaturizationConfig\n",
         "from azureml.core.experiment import Experiment\n",
-        "from azureml.train.automl import AutoMLConfig\n",
-        "from azureml.automl.core.featurization import FeaturizationConfig"
+        "from azureml.core.workspace import Workspace\n",
+        "from azureml.train.automl import AutoMLConfig\n"
       ]
     },
     {
@@ -81,7 +82,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -112,7 +113,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Run History Name\"] = experiment_name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "outputDf.T"
       ]
@@ -262,22 +263,14 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "train.to_csv(r\"./dominicks_OJ_train.csv\", index=None, header=True)\n",
-        "test.to_csv(r\"./dominicks_OJ_test.csv\", index=None, header=True)"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
+        "from azureml.data.dataset_factory import TabularDatasetFactory\n",
+        "\n",
         "datastore = ws.get_default_datastore()\n",
-        "datastore.upload_files(\n",
-        "    files=[\"./dominicks_OJ_train.csv\", \"./dominicks_OJ_test.csv\"],\n",
-        "    target_path=\"dataset/\",\n",
-        "    overwrite=True,\n",
-        "    show_progress=True,\n",
+        "train_dataset = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    train, target=(datastore, \"dataset/\"), name=\"dominicks_OJ_train\"\n",
+        ")\n",
+        "test_dataset = TabularDatasetFactory.register_pandas_dataframe(\n",
+        "    test, target=(datastore, \"dataset/\"), name=\"dominicks_OJ_test\"\n",
         ")"
       ]
     },
@@ -288,22 +281,6 @@
         "### Create dataset for training"
       ]
     },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "from azureml.core.dataset import Dataset\n",
-        "\n",
-        "train_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=datastore.path(\"dataset/dominicks_OJ_train.csv\")\n",
-        ")\n",
-        "test_dataset = Dataset.Tabular.from_delimited_files(\n",
-        "    path=datastore.path(\"dataset/dominicks_OJ_test.csv\")\n",
-        ")"
-      ]
-    },
     {
       "cell_type": "code",
       "execution_count": null,
@@ -390,7 +367,7 @@
         "|-|-|\n",
         "|**time_column_name**|The name of your time column.|\n",
         "|**forecast_horizon**|The forecast horizon is how many periods forward you would like to forecast. This integer horizon is in units of the timeseries frequency (e.g. daily, weekly).|\n",
-        "|**time_series_id_column_names**|The column names used to uniquely identify the time series in data that has multiple rows with the same timestamp. If the time series identifiers are not defined, the data set is assumed to be one time series.|\n",
+        "|**time_series_id_column_names**|This optional parameter represents the column names used to uniquely identify the time series in data that has multiple rows with the same timestamp. If the time series identifiers are not defined or incorrectly defined, time series identifiers will be created automatically if they exist.|\n",
         "|**freq**|Forecast frequency. This optional parameter represents the period with which the forecast is desired, for example, daily, weekly, yearly, etc. Use this parameter for the correction of time series containing irregular data points or for padding of short time series. The frequency needs to be a pandas offset alias. Please refer to [pandas documentation](https://pandas.pydata.org/pandas-docs/stable/user_guide/timeseries.html#dateoffset-objects) for more information."
       ]
     },
@@ -402,7 +379,7 @@
         "\n",
         "The [AutoMLConfig](https://docs.microsoft.com/en-us/python/api/azureml-train-automl-client/azureml.train.automl.automlconfig.automlconfig?view=azure-ml-py) object defines the settings and data for an AutoML training job. Here, we set necessary inputs like the task type, the number of AutoML iterations to try, the training data, and cross-validation parameters.\n",
         "\n",
-        "For forecasting tasks, there are some additional parameters that can be set in the `ForecastingParameters` class: the name of the column holding the date/time, the timeseries id column names, and the maximum forecast horizon. A time column is required for forecasting, while the time_series_id is optional. If time_series_id columns are not given, AutoML assumes that the whole dataset is a single time-series. We also pass a list of columns to drop prior to modeling. The _logQuantity_ column is completely correlated with the target quantity, so it must be removed to prevent a target leak.\n",
+        "For forecasting tasks, there are some additional parameters that can be set in the `ForecastingParameters` class: the name of the column holding the date/time, the timeseries id column names, and the maximum forecast horizon. A time column is required for forecasting, while the time_series_id is optional. If time_series_id columns are not given or incorrectly given, AutoML automatically creates time_series_id columns if they exist. We also pass a list of columns to drop prior to modeling. The _logQuantity_ column is completely correlated with the target quantity, so it must be removed to prevent a target leak.\n",
         "\n",
         "The forecast horizon is given in units of the time-series frequency; for instance, the OJ series frequency is weekly, so a horizon of 20 means that a trained model will estimate sales up to 20 weeks beyond the latest date in the training data for each series. In this example, we set the forecast horizon to the number of samples per series in the test set (n_test_periods). Generally, the value of this parameter will be dictated by business needs. For example, a demand planning application that estimates the next month of sales should set the horizon according to suitable planning time-scales. Please see the [energy_demand notebook](https://github.com/Azure/MachineLearningNotebooks/tree/master/how-to-use-azureml/automated-machine-learning/forecasting-energy-demand) for more discussion of forecast horizon.\n",
         "\n",
@@ -445,7 +422,6 @@
         "forecasting_parameters = ForecastingParameters(\n",
         "    time_column_name=time_column_name,\n",
         "    forecast_horizon=n_test_periods,\n",
-        "    time_series_id_column_names=time_series_id_column_names,\n",
         "    freq=\"W-THU\",  # Set the forecast frequency to be weekly (start on each Thursday)\n",
         ")\n",
         "\n",
@@ -496,8 +472,8 @@
       "cell_type": "markdown",
       "metadata": {},
       "source": [
-        "### Retrieve the Best Model\n",
-        "Each run within an Experiment stores serialized (i.e. pickled) pipelines from the AutoML iterations. We can now retrieve the pipeline with the best performance on the validation dataset:"
+        "### Retrieve the Best Run details\n",
+        "Below we retrieve the best Run object from among all the runs in the experiment."
       ]
     },
     {
@@ -506,9 +482,9 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = remote_run.get_output()\n",
-        "print(fitted_model.steps)\n",
-        "model_name = best_run.properties[\"model_name\"]"
+        "best_run = remote_run.get_best_child()\n",
+        "model_name = best_run.properties[\"model_name\"]\n",
+        "best_run"
       ]
     },
     {
@@ -526,16 +502,16 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "custom_featurizer = fitted_model.named_steps[\"timeseriestransformer\"]"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "custom_featurizer.get_featurization_summary()"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "fs = pd.DataFrame.from_records(records)\n",
+        "\n",
+        "# View a summary of the featurization \n",
+        "fs[[\"RawFeatureName\", \"TypeDetected\", \"Dropped\", \"EngineeredFeatureCount\", \"Transformations\"]]"
       ]
     },
     {

how-to-use-azureml/automated-machine-learning/forecasting-recipes-univariate/auto-ml-forecasting-univariate-recipe-run-experiment.ipynb

@@ -229,7 +229,7 @@
         "output[\"Resource Group\"] = ws.resource_group\n",
         "output[\"Location\"] = ws.location\n",
         "output[\"Run History Name\"] = experiment_name\n",
-        "pd.set_option(\"display.max_colwidth\", -1)\n",
+        "pd.set_option(\"display.max_colwidth\", None)\n",
         "outputDf = pd.DataFrame(data=output, index=[\"\"])\n",
         "print(outputDf.T)"
       ]

how-to-use-azureml/automated-machine-learning/forecasting-recipes-univariate/helper_functions.py

@@ -46,11 +46,11 @@ def kpss_test(series, **kw):
     """
     if kw["store"]:
         statistic, p_value, critical_values, rstore = stattools.kpss(
-            series, regression=kw["reg_type"], lags=kw["lags"], store=kw["store"]
+            series, regression=kw["reg_type"], nlags=kw["lags"], store=kw["store"]
         )
     else:
         statistic, p_value, lags, critical_values = stattools.kpss(
-            series, regression=kw["reg_type"], lags=kw["lags"]
+            series, regression=kw["reg_type"], nlags=kw["lags"]
         )
     output = {
         "statistic": statistic,

how-to-use-azureml/automated-machine-learning/local-run-classification-credit-card-fraud/auto-ml-classification-credit-card-fraud-local.ipynb

@@ -96,7 +96,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -119,7 +119,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Experiment Name'] = experiment.name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]

how-to-use-azureml/automated-machine-learning/regression-explanation-featurization/auto-ml-regression-explanation-featurization.ipynb

@@ -68,6 +68,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
+        "import json\n",
         "import logging\n",
         "\n",
         "from matplotlib import pyplot as plt\n",
@@ -95,7 +96,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -117,7 +118,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Experiment Name'] = experiment.name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]
@@ -339,16 +340,8 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "best_run, fitted_model = remote_run.get_output()"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "best_run_customized, fitted_model_customized = remote_run.get_output()"
+        "# Retrieve the best Run object\n",
+        "best_run = remote_run.get_best_child()"
       ]
     },
     {
@@ -357,7 +350,7 @@
       "source": [
         "## Transparency\n",
         "\n",
-        "View updated featurization summary"
+        "View featurization summary for the best model - to study how different features were transformed. This is stored as a JSON file in the outputs directory for the run."
       ]
     },
     {
@@ -366,41 +359,14 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "custom_featurizer = fitted_model_customized.named_steps['datatransformer']"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "custom_featurizer.get_featurization_summary()"
-      ]
-    },
-    {
-      "cell_type": "markdown",
-      "metadata": {},
-      "source": [
-        "is_user_friendly=False allows for more detailed summary for transforms being applied"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "custom_featurizer.get_featurization_summary(is_user_friendly=False)"
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "custom_featurizer.get_stats_feature_type_summary()"
+        "# Download the featurization summary JSON file locally\n",
+        "best_run.download_file(\"outputs/featurization_summary.json\", \"featurization_summary.json\")\n",
+        "\n",
+        "# Render the JSON as a pandas DataFrame\n",
+        "with open(\"featurization_summary.json\", \"r\") as f:\n",
+        "    records = json.load(f)\n",
+        "\n",
+        "pd.DataFrame.from_records(records)"
       ]
     },
     {
@@ -881,7 +847,7 @@
       "outputs": [],
       "source": [
         "%matplotlib inline\n",
-        "test_pred = plt.scatter(y_test, y_pred_test, color='')\n",
+        "test_pred = plt.scatter(y_test, y_pred_test, color=None)\n",
         "test_test = plt.scatter(y_test, y_test, color='g')\n",
         "plt.legend((test_pred, test_test), ('prediction', 'truth'), loc='upper left', fontsize=8)\n",
         "plt.show()"

how-to-use-azureml/automated-machine-learning/regression-explanation-featurization/score_explain.py

@@ -2,6 +2,7 @@ import pandas as pd
 import joblib
 from azureml.core.model import Model
 from azureml.train.automl.runtime.automl_explain_utilities import automl_setup_model_explanations
+import scipy as sp
 
 
 def init():
@@ -18,6 +19,22 @@ def init():
     scoring_explainer = joblib.load(scoring_explainer_path)
 
 
+def is_multi_dimensional(matrix):
+    if hasattr(matrix, 'ndim') and matrix.ndim > 1:
+        return True
+    if hasattr(matrix, 'shape') and matrix.shape[1]:
+        return True
+    return False
+
+
+def convert_matrix(matrix):
+    if sp.sparse.issparse(matrix):
+        matrix = matrix.todense()
+    if is_multi_dimensional(matrix):
+        matrix = matrix.tolist()
+    return matrix
+
+
 def run(raw_data):
     # Get predictions and explanations for each data point
     data = pd.read_json(raw_data, orient='records')
@@ -28,8 +45,12 @@ def run(raw_data):
                                                                  X_test=data, task='regression')
     # Retrieve model explanations for engineered explanations
     engineered_local_importance_values = scoring_explainer.explain(automl_explainer_setup_obj.X_test_transform)
+    engineered_local_importance_values = convert_matrix(engineered_local_importance_values)
+
     # Retrieve model explanations for raw explanations
     raw_local_importance_values = scoring_explainer.explain(automl_explainer_setup_obj.X_test_transform, get_raw=True)
+    raw_local_importance_values = convert_matrix(raw_local_importance_values)
+
     # You can return any data type as long as it is JSON-serializable
     return {'predictions': predictions.tolist(),
             'engineered_local_importance_values': engineered_local_importance_values,

how-to-use-azureml/automated-machine-learning/regression/auto-ml-regression.ipynb

@@ -92,7 +92,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },
@@ -115,7 +115,7 @@
         "output['Resource Group'] = ws.resource_group\n",
         "output['Location'] = ws.location\n",
         "output['Run History Name'] = experiment_name\n",
-        "pd.set_option('display.max_colwidth', -1)\n",
+        "pd.set_option('display.max_colwidth', None)\n",
         "outputDf = pd.DataFrame(data = output, index = [''])\n",
         "outputDf.T"
       ]
@@ -430,7 +430,7 @@
       "outputs": [],
       "source": [
         "%matplotlib inline\n",
-        "test_pred = plt.scatter(y_test, y_pred_test, color='')\n",
+        "test_pred = plt.scatter(y_test, y_pred_test, color=None)\n",
         "test_test = plt.scatter(y_test, y_test, color='g')\n",
         "plt.legend((test_pred, test_test), ('prediction', 'truth'), loc='upper left', fontsize=8)\n",
         "plt.show()"

how-to-use-azureml/deployment/deploy-to-local/register-model-deploy-local-advanced.ipynb

@@ -81,7 +81,7 @@
       "source": [
         "## Create trained model\n",
         "\n",
-        "For this example, we will train a small model on scikit-learn's [diabetes dataset](https://scikit-learn.org/stable/datasets/index.html#diabetes-dataset). "
+        "For this example, we will train a small model on scikit-learn's [diabetes dataset](https://scikit-learn.org/stable/datasets/toy_dataset.html#diabetes-dataset). "
       ]
     },
     {
@@ -263,7 +263,7 @@
         "\n",
         "# explicitly set base_image to None when setting base_dockerfile\n",
         "myenv.docker.base_image = None\n",
-        "myenv.docker.base_dockerfile = \"FROM mcr.microsoft.com/azureml/base:intelmpi2018.3-ubuntu16.04\\nRUN echo \\\"this is test\\\"\"\n",
+        "myenv.docker.base_dockerfile = \"FROM mcr.microsoft.com/azureml/openmpi4.1.0-ubuntu20.04\\nRUN echo \\\"this is test\\\"\"\n",
         "myenv.inferencing_stack_version = \"latest\"\n",
         "\n",
         "inference_config = InferenceConfig(source_directory=source_directory,\n",

how-to-use-azureml/deployment/onnx/onnx-inference-facial-expression-recognition-deploy.ipynb

@@ -70,7 +70,7 @@
         "\n",
         "import urllib.request\n",
         "\n",
-        "onnx_model_url = \"https://github.com/onnx/models/blob/master/vision/body_analysis/emotion_ferplus/model/emotion-ferplus-7.tar.gz?raw=true\"\n",
+        "onnx_model_url = \"https://github.com/onnx/models/blob/main/vision/body_analysis/emotion_ferplus/model/emotion-ferplus-7.tar.gz?raw=true\"\n",
         "\n",
         "urllib.request.urlretrieve(onnx_model_url, filename=\"emotion-ferplus-7.tar.gz\")\n",
         "\n",

how-to-use-azureml/deployment/onnx/onnx-inference-mnist-deploy.ipynb

@@ -70,7 +70,7 @@
         "\n",
         "import urllib.request\n",
         "\n",
-        "onnx_model_url = \"https://github.com/onnx/models/blob/master/vision/classification/mnist/model/mnist-7.tar.gz?raw=true\"\n",
+        "onnx_model_url = \"https://github.com/onnx/models/blob/main/vision/classification/mnist/model/mnist-7.tar.gz?raw=true\"\n",
         "\n",
         "urllib.request.urlretrieve(onnx_model_url, filename=\"mnist-7.tar.gz\")"
       ]

how-to-use-azureml/explain-model/azure-integration/gpu-explanation/train-explain-model-gpu-tree-explainer.ipynb

@@ -106,7 +106,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

how-to-use-azureml/explain-model/azure-integration/remote-explanation/explain-model-on-amlcompute.yml

@@ -11,4 +11,4 @@ dependencies:
   - matplotlib
   - azureml-dataset-runtime
   - ipywidgets
-  - raiwidgets~=0.10.0
+  - raiwidgets~=0.17.0

how-to-use-azureml/explain-model/azure-integration/run-history/save-retrieve-explanations-run-history.yml

@@ -10,4 +10,5 @@ dependencies:
   - ipython
   - matplotlib
   - ipywidgets
-  - raiwidgets~=0.10.0
+  - raiwidgets~=0.17.0
+  - packaging>=20.9

how-to-use-azureml/explain-model/azure-integration/scoring-time/train-explain-model-locally-and-deploy.ipynb

@@ -324,13 +324,15 @@
       "outputs": [],
       "source": [
         "from azureml.core.conda_dependencies import CondaDependencies \n",
+        "import sys\n",
         "\n",
         "# azureml-defaults is required to host the model as a web service.\n",
         "azureml_pip_packages = [\n",
         "    'azureml-defaults', 'azureml-core', 'azureml-telemetry',\n",
         "    'azureml-interpret'\n",
         "]\n",
-        " \n",
+        "\n",
+        "python_version = '{0}.{1}'.format(sys.version_info[0], sys.version_info[1])\n",
         "\n",
         "# Note: this is to pin the scikit-learn and pandas versions to be same as notebook.\n",
         "# In production scenario user would choose their dependencies\n",
@@ -354,7 +356,9 @@
         "# the submitted job is run in.  Note the remote environment(s) needs to be similar to the local\n",
         "# environment, otherwise if a model is trained or deployed in a different environment this can\n",
         "# cause errors.  Please take extra care when specifying your dependencies in a production environment.\n",
-        "myenv = CondaDependencies.create(pip_packages=['pyyaml', sklearn_dep, pandas_dep] + azureml_pip_packages)\n",
+        "myenv = CondaDependencies.create(\n",
+        "    python_version=python_version,\n",
+        "    pip_packages=['pyyaml', sklearn_dep, pandas_dep] + azureml_pip_packages)\n",
         "\n",
         "with open(\"myenv.yml\",\"w\") as f:\n",
         "    f.write(myenv.serialize_to_string())\n",
@@ -387,7 +391,7 @@
         "\n",
         "\n",
         "aciconfig = AciWebservice.deploy_configuration(cpu_cores=1, \n",
-        "                                               memory_gb=1, \n",
+        "                                               memory_gb=2, \n",
         "                                               tags={\"data\": \"IBM_Attrition\",  \n",
         "                                                     \"method\" : \"local_explanation\"}, \n",
         "                                               description='Get local explanations for IBM Employee Attrition data')\n",

how-to-use-azureml/explain-model/azure-integration/scoring-time/train-explain-model-locally-and-deploy.yml

@@ -10,4 +10,5 @@ dependencies:
   - ipython
   - matplotlib
   - ipywidgets
-  - raiwidgets~=0.10.0
+  - raiwidgets~=0.17.0
+  - packaging>=20.9

how-to-use-azureml/explain-model/azure-integration/scoring-time/train-explain-model-on-amlcompute-and-deploy.ipynb

@@ -251,6 +251,7 @@
         "from azureml.core.runconfig import RunConfiguration\n",
         "from azureml.core.conda_dependencies import CondaDependencies\n",
         "from azureml.core.runconfig import DEFAULT_CPU_IMAGE\n",
+        "import sys\n",
         "\n",
         "# Create a new runconfig object\n",
         "run_config = RunConfiguration()\n",
@@ -268,7 +269,7 @@
         "    'azureml-defaults', 'azureml-telemetry', 'azureml-interpret'\n",
         "]\n",
         " \n",
-        "\n",
+        "python_version = '{0}.{1}'.format(sys.version_info[0], sys.version_info[1])\n",
         "\n",
         "# Note: this is to pin the scikit-learn version to be same as notebook.\n",
         "# In production scenario user would choose their dependencies\n",
@@ -293,7 +294,10 @@
         "# environment, otherwise if a model is trained or deployed in a different environment this can\n",
         "# cause errors.  Please take extra care when specifying your dependencies in a production environment.\n",
         "azureml_pip_packages.extend(['pyyaml', sklearn_dep, pandas_dep])\n",
-        "run_config.environment.python.conda_dependencies = CondaDependencies.create(pip_packages=azureml_pip_packages)\n",
+        "run_config.environment.python.conda_dependencies = CondaDependencies.create(\n",
+        "    python_version=python_version,\n",
+        "    pip_packages=azureml_pip_packages)\n",
+        "\n",
         "# Now submit a run on AmlCompute\n",
         "from azureml.core.script_run_config import ScriptRunConfig\n",
         "\n",
@@ -453,7 +457,7 @@
         "# environment, otherwise if a model is trained or deployed in a different environment this can\n",
         "# cause errors.  Please take extra care when specifying your dependencies in a production environment.\n",
         "azureml_pip_packages.extend(['pyyaml', sklearn_dep, pandas_dep])\n",
-        "myenv = CondaDependencies.create(pip_packages=azureml_pip_packages)\n",
+        "myenv = CondaDependencies.create(python_version=python_version, pip_packages=azureml_pip_packages)\n",
         "\n",
         "with open(\"myenv.yml\",\"w\") as f:\n",
         "    f.write(myenv.serialize_to_string())\n",

how-to-use-azureml/explain-model/azure-integration/scoring-time/train-explain-model-on-amlcompute-and-deploy.yml

@@ -12,4 +12,4 @@ dependencies:
   - azureml-dataset-runtime
   - azureml-core
   - ipywidgets
-  - raiwidgets~=0.10.0
+  - raiwidgets~=0.17.0

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-getting-started.ipynb

@@ -63,6 +63,8 @@
       "outputs": [],
       "source": [
         "import os\n",
+        "import requests\n",
+        "import tempfile\n",
         "import azureml.core\n",
         "from azureml.core import Workspace, Experiment, Datastore\n",
         "from azureml.widgets import RunDetails\n",
@@ -158,9 +160,14 @@
       "metadata": {},
       "outputs": [],
       "source": [
+        "# download data file from remote\n",
+        "response = requests.get(\"https://dprepdata.blob.core.windows.net/demo/Titanic.csv\")\n",
+        "titanic_file = os.path.join(tempfile.mkdtemp(), \"Titanic.csv\")\n",
+        "with open(titanic_file, \"w\") as f:\n",
+        "    f.write(response.content.decode(\"utf-8\"))\n",
         "# get_default_datastore() gets the default Azure Blob Store associated with your workspace.\n",
         "# Here we are reusing the def_blob_store object we obtained earlier\n",
-        "def_blob_store.upload_files([\"./20news.pkl\"], target_path=\"20newsgroups\", overwrite=True)\n",
+        "def_blob_store.upload_files([titanic_file], target_path=\"titanic\", overwrite=True)\n",
         "print(\"Upload call completed\")"
       ]
     },
@@ -286,7 +293,7 @@
         "- [**AzureBatchStep**](https://docs.microsoft.com/en-us/python/api/azureml-pipeline-steps/azureml.pipeline.steps.azurebatch_step.azurebatchstep?view=azure-ml-py): Creates a step for submitting jobs to Azure Batch\n",
         "- [**EstimatorStep**](https://docs.microsoft.com/en-us/python/api/azureml-pipeline-steps/azureml.pipeline.steps.estimator_step.estimatorstep?view=azure-ml-py): Adds a step to run Estimator in a Pipeline.\n",
         "- [**MpiStep**](https://docs.microsoft.com/en-us/python/api/azureml-pipeline-steps/azureml.pipeline.steps.mpi_step.mpistep?view=azure-ml-py): Adds a step to run a MPI job in a Pipeline.\n",
-        "- [**AutoMLStep**](https://docs.microsoft.com/en-us/python/api/azureml-train-automl/azureml.train.automl.automlstep?view=azure-ml-py): Creates a AutoML step in a Pipeline.\n",
+        "- [**AutoMLStep**](https://docs.microsoft.com/en-us/python/api/azureml-pipeline-steps/azureml.pipeline.steps.automlstep?view=azure-ml-py): Creates a AutoML step in a Pipeline.\n",
         "\n",
         "The following code will create a PythonScriptStep to be executed in the Azure Machine Learning Compute we created above using train.py, one of the files already made available in the `source_directory`.\n",
         "\n",

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-publish-and-run-using-rest-endpoint.ipynb

@@ -120,8 +120,10 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "# Uploading data to the datastore\n",
-        "data_path = def_blob_store.upload_files([\"./20news.pkl\"], target_path=\"20newsgroups\", overwrite=True)"
+        "# Specify a public dataset path\n",
+        "data_path = \"https://dprepdata.blob.core.windows.net/demo/Titanic.csv\"\n",
+        "# Or uploading data to the datastore\n",
+        "# data_path = def_blob_store.upload_files([\"./your_data.pkl\"], target_path=\"your_path\", overwrite=True)"
       ]
     },
     {
@@ -400,11 +402,11 @@
       "source": [
         "try:\n",
         "    response.raise_for_status()\n",
-        "except Exception:    \n",
+        "except Exception as ex:    \n",
         "    raise Exception('Received bad response from the endpoint: {}\\n'\n",
         "                    'Response Code: {}\\n'\n",
         "                    'Headers: {}\\n'\n",
-        "                    'Content: {}'.format(rest_endpoint, response.status_code, response.headers, response.content))\n",
+        "                    'Content: {}'.format(rest_endpoint1, response.status_code, response.headers, response.content)) from ex\n",
         "\n",
         "run_id = response.json().get('Id')\n",
         "print('Submitted pipeline run: ', run_id)"

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-use-databricks-as-compute-target.ipynb

@@ -875,7 +875,12 @@
         "\n",
         "def populate_environ():\n",
         "    parser = argparse.ArgumentParser(description='Process arguments passed to script')\n",
+        "\n",
+        "    # The AZUREML_SCRIPT_DIRECTORY_NAME argument will be filled in if the DatabricksStep\n",
+        "    # was run using a local source_directory and python_script_name\n",
         "    parser.add_argument('--AZUREML_SCRIPT_DIRECTORY_NAME')\n",
+        "\n",
+        "    # Remaining arguments are filled in for all databricks jobs and can be used to build the run context\n",
         "    parser.add_argument('--AZUREML_RUN_TOKEN')\n",
         "    parser.add_argument('--AZUREML_RUN_TOKEN_EXPIRY')\n",
         "    parser.add_argument('--AZUREML_RUN_ID')\n",
@@ -884,9 +889,10 @@
         "    parser.add_argument('--AZUREML_ARM_WORKSPACE_NAME')\n",
         "    parser.add_argument('--AZUREML_ARM_PROJECT_NAME')\n",
         "    parser.add_argument('--AZUREML_SERVICE_ENDPOINT')\n",
+        "    parser.add_argument('--AZUREML_WORKSPACE_ID')\n",
+        "    parser.add_argument('--AZUREML_EXPERIMENT_ID')\n",
         "\n",
-        "    args = parser.parse_args()\n",
-        "    os.environ['AZUREML_SCRIPT_DIRECTORY_NAME'] = args.AZUREML_SCRIPT_DIRECTORY_NAME\n",
+        "    (args, extra_args) = parser.parse_known_args()\n",
         "    os.environ['AZUREML_RUN_TOKEN'] = args.AZUREML_RUN_TOKEN\n",
         "    os.environ['AZUREML_RUN_TOKEN_EXPIRY'] = args.AZUREML_RUN_TOKEN_EXPIRY\n",
         "    os.environ['AZUREML_RUN_ID'] = args.AZUREML_RUN_ID\n",
@@ -895,10 +901,12 @@
         "    os.environ['AZUREML_ARM_WORKSPACE_NAME'] = args.AZUREML_ARM_WORKSPACE_NAME\n",
         "    os.environ['AZUREML_ARM_PROJECT_NAME'] = args.AZUREML_ARM_PROJECT_NAME\n",
         "    os.environ['AZUREML_SERVICE_ENDPOINT'] = args.AZUREML_SERVICE_ENDPOINT\n",
+        "    os.environ['AZUREML_WORKSPACE_ID'] = args.AZUREML_WORKSPACE_ID\n",
+        "    os.environ['AZUREML_EXPERIMENT_ID'] = args.AZUREML_EXPERIMENT_ID\n",
         "\n",
         "populate_environ()\n",
         "run = Run.get_context(allow_offline=False)\n",
-        "print(run._run_dto[\"parent_run_id\"])\n",
+        "print(run.parent.id)\n",
         "```"
       ]
     },
@@ -947,7 +955,7 @@
       "name": "python",
       "nbconvert_exporter": "python",
       "pygments_lexer": "ipython3",
-      "version": "3.6.2"
+      "version": "3.7.9"
     },
     "order_index": 5,
     "star_tag": [

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-with-data-dependency-steps.ipynb

@@ -213,7 +213,7 @@
         "blob_input_data = DataReference(\n",
         "    datastore=def_blob_store,\n",
         "    data_reference_name=\"test_data\",\n",
-        "    path_on_datastore=\"20newsgroups/20news.pkl\")\n",
+        "    path_on_datastore=\"titanic/Titanic.csv\")\n",
         "print(\"DataReference object created\")"
       ]
     },
@@ -382,7 +382,7 @@
         "from azureml.pipeline.core import PipelineParameter\n",
         "from azureml.data.datapath import DataPath, DataPathComputeBinding\n",
         "\n",
-        "datapath = DataPath(datastore=def_blob_store, path_on_datastore='20newsgroups/20news.pkl')\n",
+        "datapath = DataPath(datastore=def_blob_store, path_on_datastore='titanic/Titanic.csv')\n",
         "datapath_param = PipelineParameter(name=\"compare_data\", default_value=datapath)\n",
         "data_parameter1 = (datapath_param, DataPathComputeBinding(mode='mount'))"
       ]

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-with-notebook-runner-step.ipynb

@@ -42,9 +42,7 @@
         "Advantages of running your notebook as a step in pipeline:\n",
         "1. Run your notebook like a python script without converting into .py files, leveraging complete end to end experience of Azure Machine Learning Pipelines.\n",
         "2. Use pipeline intermediate data to and from the notebook along with other steps in pipeline.\n",
-        "3. Parameterize your notebook with [Pipeline Parameters](./aml-pipelines-publish-and-run-using-rest-endpoint.ipynb).\n",
-        "\n",
-        "Try some more [quick start notebooks](https://github.com/microsoft/recommenders/tree/master/notebooks/00_quick_start) with `NotebookRunnerStep`."
+        "3. Parameterize your notebook with [Pipeline Parameters](./aml-pipelines-publish-and-run-using-rest-endpoint.ipynb).\n"
       ]
     },
     {
@@ -61,6 +59,8 @@
       "outputs": [],
       "source": [
         "import os\n",
+        "import requests\n",
+        "import tempfile\n",
         "\n",
         "import azureml.core\n",
         "\n",
@@ -114,7 +114,12 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "Datastore.get(ws, \"workspaceblobstore\").upload_files([\"./20news.pkl\"], target_path=\"20newsgroups\", overwrite=True)\n",
+        "# download data file from remote\n",
+        "response = requests.get(\"https://dprepdata.blob.core.windows.net/demo/Titanic.csv\")\n",
+        "titanic_file = os.path.join(tempfile.mkdtemp(), \"Titanic.csv\")\n",
+        "with open(titanic_file, \"w\") as f:\n",
+        "    f.write(response.content.decode(\"utf-8\"))\n",
+        "Datastore.get(ws, \"workspaceblobstore\").upload_files([titanic_file], target_path=\"titanic\", overwrite=True)\n",
         "print(\"Upload call completed\")"
       ]
     },
@@ -227,7 +232,7 @@
         "input_data = DataReference(\n",
         "    datastore=Datastore.get(ws, \"workspaceblobstore\"),\n",
         "    data_reference_name=\"blob_test_data\",\n",
-        "    path_on_datastore=\"20newsgroups/20news.pkl\")\n",
+        "    path_on_datastore=\"titanic/Titanic.csv\")\n",
         "\n",
         "output_data = PipelineData(name=\"processed_data\",\n",
         "                           datastore=Datastore.get(ws, \"workspaceblobstore\"))"

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/publish_run_extract/extract.py

@@ -20,7 +20,7 @@ if not (args.output_extract is None):
     os.makedirs(args.output_extract, exist_ok=True)
     print("%s created" % args.output_extract)
 
-with open(os.path.join(args.input_extract, '20news.pkl'), 'rb') as f:
+with open(os.path.join(args.input_extract, 'Titanic.csv'), 'rb') as f:
     content = f.read()
-    with open(os.path.join(args.output_extract, '20news.pkl'), 'wb') as fw:
+    with open(os.path.join(args.output_extract, 'Titanic.csv'), 'wb') as fw:
         fw.write(content)

how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/publish_run_train/train.py

@@ -21,7 +21,7 @@ if not (args.output_train is None):
     os.makedirs(args.output_train, exist_ok=True)
     print("%s created" % args.output_train)
 
-with open(os.path.join(args.input_data, '20news.pkl'), 'rb') as f:
+with open(os.path.join(args.input_data), 'rb') as f:
     content = f.read()
-    with open(os.path.join(args.output_train, '20news.pkl'), 'wb') as fw:
+    with open(os.path.join(args.output_train, 'Titanic.csv'), 'wb') as fw:
         fw.write(content)

how-to-use-azureml/machine-learning-pipelines/nyc-taxi-data-regression-model-building/scripts/prepdata/cleanse.py

@@ -5,17 +5,6 @@ import argparse
 import os
 from azureml.core import Run
 
-
-def get_dict(dict_str):
-    pairs = dict_str.strip("{}").split("\;")
-    new_dict = {}
-    for pair in pairs:
-        key, value = pair.strip().split(":")
-        new_dict[key.strip().strip("'")] = value.strip().strip("'")
-
-    return new_dict
-
-
 print("Cleans the input data")
 
 # Get the input green_taxi_data. To learn more about how to access dataset in your script, please
@@ -23,7 +12,6 @@ print("Cleans the input data")
 run = Run.get_context()
 raw_data = run.input_datasets["raw_data"]
 
-
 parser = argparse.ArgumentParser("cleanse")
 parser.add_argument("--output_cleanse", type=str, help="cleaned taxi data directory")
 parser.add_argument("--useful_columns", type=str, help="useful columns to keep")
@@ -31,15 +19,15 @@ parser.add_argument("--columns", type=str, help="rename column pattern")
 
 args = parser.parse_args()
 
-print("Argument 1(columns to keep): %s" % str(args.useful_columns.strip("[]").split("\;")))
-print("Argument 2(columns renaming mapping): %s" % str(args.columns.strip("{}").split("\;")))
+print("Argument 1(columns to keep): %s" % str(args.useful_columns.strip("[]").split(r'\;')))
+print("Argument 2(columns renaming mapping): %s" % str(args.columns.strip("{}").split(r'\;')))
 print("Argument 3(output cleansed taxi data path): %s" % args.output_cleanse)
 
 # These functions ensure that null data is removed from the dataset,
 # which will help increase machine learning model accuracy.
 
-useful_columns = [s.strip().strip("'") for s in args.useful_columns.strip("[]").split("\;")]
-columns = get_dict(args.columns)
+useful_columns = eval(args.useful_columns.replace(';', ','))
+columns = eval(args.columns.replace(';', ','))
 
 new_df = (raw_data.to_pandas_dataframe()
           .dropna(how='all')

how-to-use-azureml/machine-learning-pipelines/nyc-taxi-data-regression-model-building/scripts/prepdata/filter.py

@@ -29,14 +29,14 @@ print("Argument (output filtered taxi data path): %s" % args.output_filter)
 combined_df = combined_df.astype({"pickup_longitude": 'float64', "pickup_latitude": 'float64',
                                   "dropoff_longitude": 'float64', "dropoff_latitude": 'float64'})
 
-latlong_filtered_df = combined_df[(combined_df.pickup_longitude <= -73.72) &
-                                  (combined_df.pickup_longitude >= -74.09) &
-                                  (combined_df.pickup_latitude <= 40.88) &
-                                  (combined_df.pickup_latitude >= 40.53) &
-                                  (combined_df.dropoff_longitude <= -73.72) &
-                                  (combined_df.dropoff_longitude >= -74.72) &
-                                  (combined_df.dropoff_latitude <= 40.88) &
-                                  (combined_df.dropoff_latitude >= 40.53)]
+latlong_filtered_df = combined_df[(combined_df.pickup_longitude <= -73.72)
+                                  & (combined_df.pickup_longitude >= -74.09)
+                                  & (combined_df.pickup_latitude <= 40.88)
+                                  & (combined_df.pickup_latitude >= 40.53)
+                                  & (combined_df.dropoff_longitude <= -73.72)
+                                  & (combined_df.dropoff_longitude >= -74.72)
+                                  & (combined_df.dropoff_latitude <= 40.88)
+                                  & (combined_df.dropoff_latitude >= 40.53)]
 
 latlong_filtered_df.reset_index(inplace=True, drop=True)
 

how-to-use-azureml/machine-learning-pipelines/nyc-taxi-data-regression-model-building/scripts/trainmodel/train_test_split.py

@@ -1,6 +1,6 @@
 import argparse
 import os
-import azureml.core
+# import azureml.core
 from azureml.core import Run
 from sklearn.model_selection import train_test_split
 
@@ -32,7 +32,7 @@ output_split_train, output_split_test = train_test_split(transformed_df, test_si
 output_split_train.reset_index(inplace=True, drop=True)
 output_split_test.reset_index(inplace=True, drop=True)
 
-if not (args.output_split_train is None and
-        args.output_split_test is None):
+if not (args.output_split_train
+        is None and args.output_split_test is None):
     write_output(output_split_train, args.output_split_train)
     write_output(output_split_test, args.output_split_test)

how-to-use-azureml/ml-frameworks/chainer/train-hyperparameter-tune-deploy-with-chainer/train-hyperparameter-tune-deploy-with-chainer.ipynb

@@ -254,6 +254,7 @@
         "- conda-forge\n",
         "dependencies:\n",
         "- python=3.6.2\n",
+        "- pip=21.3.1\n",
         "- pip:\n",
         "  - azureml-defaults\n",
         "  - azureml-opendatasets\n",

how-to-use-azureml/ml-frameworks/fastai/fastai-with-custom-docker/fastai-with-custom-docker.ipynb

@@ -199,7 +199,7 @@
         "Specify docker steps as a string:\n",
         "```python \n",
         "dockerfile = r\"\"\" \\\n",
-        "FROM mcr.microsoft.com/azureml/base:intelmpi2018.3-ubuntu16.04\n",
+        "FROM mcr.microsoft.com/azureml/openmpi4.1.0-ubuntu20.04\n",
         "RUN echo \"Hello from custom container!\" \\\n",
         "\"\"\"\n",
         "```\n",

how-to-use-azureml/ml-frameworks/keras/train-hyperparameter-tune-deploy-with-keras/train-hyperparameter-tune-deploy-with-keras.ipynb

@@ -431,6 +431,7 @@
         "- conda-forge\n",
         "dependencies:\n",
         "- python=3.6.2\n",
+        "- pip=21.3.1\n",
         "- pip:\n",
         "  - h5py<=2.10.0\n",
         "  - azureml-defaults\n",

how-to-use-azureml/ml-frameworks/pytorch/train-hyperparameter-tune-deploy-with-pytorch/train-hyperparameter-tune-deploy-with-pytorch.ipynb

@@ -262,6 +262,7 @@
         "- conda-forge\n",
         "dependencies:\n",
         "- python=3.6.2\n",
+        "- pip=21.3.1\n",
         "- pip:\n",
         "  - azureml-defaults\n",
         "  - torch==1.6.0\n",

how-to-use-azureml/reinforcement-learning/cartpole-on-single-compute/cartpole_sc.ipynb

@@ -261,7 +261,7 @@
         "    \n",
         "    # 2.  Execute the Python process via the xvfb-run command to set up the headless display driver.\n",
         "    xvfb_env.python.user_managed_dependencies = True\n",
-        "    xvfb_env.python.interpreter_path = \"xvfb-run -s '-screen 0 640x480x16 -ac +extension GLX +render' python\"\n",
+        "    xvfb_env.python.interpreter_path = \"xvfb-run -s '-screen 0 640x480x24 -ac +extension GLX +render' python\"\n",
         "\n",
         "\n",
         "training_estimator = ReinforcementLearningEstimator(\n",
@@ -718,7 +718,7 @@
         "# 2.  Execute the Python process via the xvfb-run command to set up the headless display driver.\n",
         "xvfb_env.python.user_managed_dependencies = True\n",
         "if video_capture:\n",
-        "    xvfb_env.python.interpreter_path = \"xvfb-run -s '-screen 0 640x480x16 -ac +extension GLX +render' python\"\n",
+        "    xvfb_env.python.interpreter_path = \"xvfb-run -s '-screen 0 640x480x24 -ac +extension GLX +render' python\"\n",
         "\n",
         "\n",
         "rollout_estimator = ReinforcementLearningEstimator(\n",

how-to-use-azureml/reinforcement-learning/cartpole-on-single-compute/files/docker/Dockerfile

@@ -26,6 +26,6 @@ RUN conda install -y conda=4.7.12 python=3.7 && conda clean -ay && \
     ray[rllib,dashboard,tune]==0.8.3 \
     psutil \
     setproctitle \
-    gym[atari] && \
+    gym[classic_control] && \
     conda install -y -c conda-forge x264='1!152.20180717' ffmpeg=4.0.2 && \
     conda install -c anaconda opencv

how-to-use-azureml/responsible-ai/auto-ml-regression-responsibleai/auto-ml-regression-responsibleai.ipynb

@@ -95,7 +95,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

how-to-use-azureml/responsible-ai/visualize-upload-loan-decision/rai-loan-decision.yml

@@ -8,5 +8,6 @@ dependencies:
   - matplotlib
   - azureml-dataset-runtime
   - ipywidgets
-  - raiwidgets~=0.13.0
+  - raiwidgets~=0.17.0
   - liac-arff
+  - packaging>=20.9

how-to-use-azureml/track-and-monitor-experiments/logging-api/logging-api.ipynb

@@ -100,7 +100,7 @@
         "\n",
         "# Check core SDK version number\n",
         "\n",
-        "print(\"This notebook was created using SDK version 1.36.0, you are currently running version\", azureml.core.VERSION)"
+        "print(\"This notebook was created using SDK version 1.39.0, you are currently running version\", azureml.core.VERSION)"
       ]
     },
     {

how-to-use-azureml/training/using-environments/using-environments.ipynb

@@ -184,24 +184,6 @@
         "myenv.python.conda_dependencies=conda_dep"
       ]
     },
-    {
-      "cell_type": "markdown",
-      "metadata": {},
-      "source": [
-        "### Specify environment variables\n",
-        "\n",
-        "You can add environment variables to your environment. These then become available using ```os.environ.get``` in your training script."
-      ]
-    },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "myenv.environment_variables = {\"MESSAGE\":\"Hello from Azure Machine Learning\"}"
-      ]
-    },
     {
       "cell_type": "markdown",
       "metadata": {},

index.md

@@ -28,6 +28,7 @@ Machine Learning notebook samples and encourage efficient retrieval of topics an
 | [Classification of credit card fraudulent transactions using Automated ML](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/experimental/classification-credit-card-fraud-local-managed/auto-ml-classification-credit-card-fraud-local-managed.ipynb) | Classification | Creditcard | AML Compute | None | None | AutomatedML |
 | [Automated ML run with featurization and model explainability.](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/regression-explanation-featurization/auto-ml-regression-explanation-featurization.ipynb) | Regression | MachineData | AML | ACI | None | featurization, explainability, remote_run, AutomatedML |
 | [Automated ML run with featurization and model explainability.](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/responsible-ai/auto-ml-regression-responsibleai/auto-ml-regression-responsibleai.ipynb) | Regression | MachineData | AML | ACI | None | featurization, explainability, remote_run, AutomatedML |
+| [auto-ml-forecasting-backtest-single-model](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-backtest-single-model/auto-ml-forecasting-backtest-single-model.ipynb) |  | None | Remote | None | Azure ML AutoML |  |
 | :star:[Azure Machine Learning Pipeline with DataTranferStep](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-data-transfer.ipynb) | Demonstrates the use of DataTranferStep | Custom | ADF | None | Azure ML | None |
 | [Getting Started with Azure Machine Learning Pipelines](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-getting-started.ipynb) | Getting Started notebook for ANML Pipelines | Custom | AML Compute | None | Azure ML | None |
 | [Azure Machine Learning Pipeline with AzureBatchStep](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/machine-learning-pipelines/intro-to-pipelines/aml-pipelines-how-to-use-azurebatch-to-run-a-windows-executable.ipynb) | Demonstrates the use of AzureBatchStep | Custom | Azure Batch | None | Azure ML | None |
@@ -106,8 +107,9 @@ Machine Learning notebook samples and encourage efficient retrieval of topics an
 | [azure-ml-with-nvidia-rapids](https://github.com/Azure/MachineLearningNotebooks/blob/master//contrib/RAPIDS/azure-ml-with-nvidia-rapids.ipynb) |  |  |  |  |  |  |
 | [auto-ml-continuous-retraining](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/continuous-retraining/auto-ml-continuous-retraining.ipynb) |  |  |  |  |  |  |
 | [auto-ml-regression-model-proxy](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/experimental/regression-model-proxy/auto-ml-regression-model-proxy.ipynb) |  |  |  |  |  |  |
-| [auto-ml-forecasting-beer-remote](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-beer-remote/auto-ml-forecasting-beer-remote.ipynb) |  |  |  |  |  |  |
+| [auto-ml-forecasting-backtest-many-models](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-backtest-many-models/auto-ml-forecasting-backtest-many-models.ipynb) |  |  |  |  |  |  |
 | [auto-ml-forecasting-energy-demand](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-energy-demand/auto-ml-forecasting-energy-demand.ipynb) |  |  |  |  |  |  |
+| [auto-ml-forecasting-github-dau](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-github-dau/auto-ml-forecasting-github-dau.ipynb) |  |  |  |  |  |  |
 | [auto-ml-forecasting-hierarchical-timeseries](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-hierarchical-timeseries/auto-ml-forecasting-hierarchical-timeseries.ipynb) |  |  |  |  |  |  |
 | [auto-ml-forecasting-many-models](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-many-models/auto-ml-forecasting-many-models.ipynb) |  |  |  |  |  |  |
 | [auto-ml-forecasting-univariate-recipe-experiment-settings](https://github.com/Azure/MachineLearningNotebooks/blob/master//how-to-use-azureml/automated-machine-learning/forecasting-recipes-univariate/auto-ml-forecasting-univariate-recipe-experiment-settings.ipynb) |  |  |  |  |  |  |

setup-environment/configuration.ipynb

@@ -102,7 +102,7 @@
       "source": [
         "import azureml.core\n",
         "\n",
-        "print(\"This notebook was created using version 1.36.0 of the Azure ML SDK\")\n",
+        "print(\"This notebook was created using version 1.39.0 of the Azure ML SDK\")\n",
         "print(\"You are currently using version\", azureml.core.VERSION, \"of the Azure ML SDK\")"
       ]
     },

tutorials/compute-instance-quickstarts/quickstart-azureml-in-10mins/quickstart-azureml-in-10mins.ipynb

@@ -19,7 +19,7 @@
       "source": [
         "# Quickstart: Train and deploy a model in Azure Machine Learning in 10 minutes\n",
         "\n",
-        "In this quickstart, learn how to get started with Azure Machine Learning. You'll train an image classification model using the [MNIST](https://azure.microsoft.com/services/open-datasets/catalog/mnist/) dataset.\n",
+        "In this quickstart, learn how to get started with Azure Machine Learning. You'll train an image classification model using the [MNIST](https://docs.microsoft.com/azure/open-datasets/dataset-mnist) dataset.\n",
         "\n",
         "You'll learn how to:\n",
         "\n",
@@ -280,7 +280,7 @@
         "# get a curated environment\n",
         "env = Environment.get(\n",
         "    workspace=ws, \n",
-        "    name=\"AzureML-sklearn-0.24.1-ubuntu18.04-py37-cpu-inference\",\n",
+        "    name=\"AzureML-sklearn-1.0-ubuntu20.04-py38-cpu\",\n",
         "    version=1\n",
         ")\n",
         "env.inferencing_stack_version='latest'\n",

tutorials/compute-instance-quickstarts/quickstart-azureml-python-sdk/quickstart-azureml-python-sdk.ipynb

@@ -21,7 +21,7 @@
         "\n",
         "In this quickstart, you learn how to submit a batch training job using the Python SDK. In this example, we submit the job to the 'local' machine (the compute instance you are running this notebook on). However, you can use exactly the same method to submit the job to different compute targets (for example, AKS, Azure Machine Learning Compute Cluster, Synapse, etc) by changing a single line of code. A full list of support compute targets can be viewed [here](https://docs.microsoft.com/en-us/azure/machine-learning/concept-compute-target). \n",
         "\n",
-        "This quickstart trains a simple logistic regression using the [MNIST](https://azure.microsoft.com/services/open-datasets/catalog/mnist/) dataset and [scikit-learn](http://scikit-learn.org) with Azure Machine Learning.  MNIST is a popular dataset consisting of 70,000 grayscale images. Each image is a handwritten digit of 28x28 pixels, representing a number from 0 to 9. The goal is to create a multi-class classifier to identify the digit a given image represents. \n",
+        "This quickstart trains a simple logistic regression using the [MNIST](https://docs.microsoft.com/azure/open-datasets/dataset-mnist) dataset and [scikit-learn](http://scikit-learn.org) with Azure Machine Learning.  MNIST is a popular dataset consisting of 70,000 grayscale images. Each image is a handwritten digit of 28x28 pixels, representing a number from 0 to 9. The goal is to create a multi-class classifier to identify the digit a given image represents. \n",
         "\n",
         "You will learn how to:\n",
         "\n",

tutorials/compute-instance-quickstarts/quickstart-azureml-python-sdk/src/train.py

@@ -2,7 +2,7 @@ import argparse
 import os
 import numpy as np
 import glob
-import joblib
+# import joblib
 import mlflow
 
 from sklearn.linear_model import LogisticRegression
@@ -30,8 +30,7 @@ X_train = (
             os.path.join(data_folder, "**/train-images-idx3-ubyte.gz"), recursive=True
         )[0],
         False,
-    ) /
-    255.0
+    ) / 255.0
 )
 X_test = (
     load_data(
@@ -39,8 +38,7 @@ X_test = (
             os.path.join(data_folder, "**/t10k-images-idx3-ubyte.gz"), recursive=True
         )[0],
         False,
-    ) /
-    255.0
+    ) / 255.0
 )
 y_train = load_data(
     glob.glob(

tutorials/create-first-ml-experiment/tutorial-1st-experiment-sdk-train.ipynb

@@ -145,7 +145,7 @@
       "source": [
         "from sklearn.linear_model import Ridge\n",
         "from sklearn.metrics import mean_squared_error\n",
-        "from sklearn.externals import joblib\n",
+        "import joblib\n",
         "import math\n",
         "\n",
         "alphas = [0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9, 1.0]\n",

tutorials/image-classification-mnist-data/img-classification-part1-training.ipynb

@@ -17,7 +17,7 @@
         "\n",
         "In this tutorial, you train a machine learning model on remote compute resources. You'll use the training and deployment workflow for Azure Machine Learning service (preview) in a Python Jupyter notebook.  You can then use the notebook as a template to train your own machine learning model with your own data. This tutorial is **part one of a two-part tutorial series**.  \n",
         "\n",
-        "This tutorial trains a simple logistic regression using the [MNIST](https://azure.microsoft.com/services/open-datasets/catalog/mnist/) dataset and [scikit-learn](http://scikit-learn.org) with Azure Machine Learning.  MNIST is a popular dataset consisting of 70,000 grayscale images. Each image is a handwritten digit of 28x28 pixels, representing a number from 0 to 9. The goal is to create a multi-class classifier to identify the digit a given image represents. \n",
+        "This tutorial trains a simple logistic regression using the [MNIST](https://docs.microsoft.com/azure/open-datasets/dataset-mnist) dataset and [scikit-learn](http://scikit-learn.org) with Azure Machine Learning.  MNIST is a popular dataset consisting of 70,000 grayscale images. Each image is a handwritten digit of 28x28 pixels, representing a number from 0 to 9. The goal is to create a multi-class classifier to identify the digit a given image represents. \n",
         "\n",
         "Learn how to:\n",
         "\n",

tutorials/image-classification-mnist-data/img-classification-part3-deploy-encrypted.ipynb

@@ -156,7 +156,7 @@
         "\n",
         "### Create scoring script\n",
         "\n",
-        "Create the scoring script, called score.py, used by the web service call to show how to use the model.\n",
+        "Create the scoring script, called score_encrypted.py, used by the web service call to show how to use the model.\n",
         "\n",
         "You must include two required functions into the scoring script:\n",
         "* The `init()` function, which typically loads the model into a global object. This function is run only once when the Docker container is started. \n",
@@ -171,7 +171,7 @@
       "metadata": {},
       "outputs": [],
       "source": [
-        "%%writefile score.py\n",
+        "%%writefile score_encrypted.py\n",
         "import json\n",
         "import os\n",
         "import pickle\n",
@@ -252,7 +252,7 @@
         "\n",
         "1. Create environment object containing dependencies needed by the model using the environment file (`myenv.yml`)\n",
         "1. Create inference configuration necessary to deploy the model as a web service using:\n",
-        "   * The scoring file (`score.py`)\n",
+        "   * The scoring file (`score_encrypted.py`)\n",
         "   * envrionment object created in previous step\n",
         "1. Deploy the model to the ACI container.\n",
         "1. Get the web service HTTP endpoint."
@@ -283,7 +283,7 @@
         "model = Model(ws, 'sklearn_mnist')\n",
         "\n",
         "myenv = Environment.get(workspace=ws, name=\"tutorial-encryption-env\")\n",
-        "inference_config = InferenceConfig(entry_script=\"score.py\", environment=myenv)\n",
+        "inference_config = InferenceConfig(entry_script=\"score_encrypted.py\", environment=myenv)\n",
         "\n",
         "service_name = 'sklearn-mnist-svc-' + str(uuid.uuid4())[:4]\n",
         "service = Model.deploy(workspace=ws, \n",