Guided Investigation - Process-Alerts.ipynb

{
  "cells": [
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "# Alert Investigation - Windows Process Alerts\n",
        "<details>\n",
        "    <summary> <u>Details...</u></summary>\n",
        "**Notebook Version:** 1.1<br>\n",
        "\n",
        "**Data Sources Used**:<br>\n",
        "- Log Analytics/Microsoft Sentinel\n",
        "    - SecurityAlert \n",
        "    - SecurityEvent\n",
        "<br>\n",
        "- Threat Intelligence Providers (Optional)\n",
        "    - OTX (https://otx.alienvault.com/)\n",
        "    - VirusTotal (https://www.virustotal.com/)\n",
        "    - XForce (https://www.ibm.com/security/xforce)\n",
        "</details>\n",
        "\n",
        "This notebook is intended for triage and investigation of security alerts related to process execution. It is specifically targeted at alerts triggered by suspicious process activity on Windows hosts. "
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "toc": true
      },
      "source": [
        "<h1>Table of Contents<span class=\"tocSkip\"></span></h1>\n",
        "<div class=\"toc\"><ul class=\"toc-item\"><li><span><a href=\"#Hunting-Hypothesis\" data-toc-modified-id=\"Hunting-Hypothesis-1\"><span class=\"toc-item-num\">1&nbsp;&nbsp;</span>Hunting Hypothesis</a></span></li><li><span><a href=\"#Notebook-Initialization\" data-toc-modified-id=\"Notebook-Initialization-2\"><span class=\"toc-item-num\">2&nbsp;&nbsp;</span>Notebook Initialization</a></span><ul class=\"toc-item\"><li><span><a href=\"#Get-WorkspaceId-and-Authenticate-to-Log-Analytics\" data-toc-modified-id=\"Get-WorkspaceId-and-Authenticate-to-Log-Analytics-2.1\"><span class=\"toc-item-num\">2.1&nbsp;&nbsp;</span>Get WorkspaceId and Authenticate to Log Analytics</a></span></li></ul></li><li><span><a href=\"#Get-List-of-Alerts\" data-toc-modified-id=\"Get-List-of-Alerts-3\"><span class=\"toc-item-num\">3&nbsp;&nbsp;</span>Get List of Alerts</a></span></li><li><span><a href=\"#Choose-Alert-to-Investigate\" data-toc-modified-id=\"Choose-Alert-to-Investigate-4\"><span class=\"toc-item-num\">4&nbsp;&nbsp;</span>Choose Alert to Investigate</a></span></li><li><span><a href=\"#Extract-properties-and-entities-from-Alert\" data-toc-modified-id=\"Extract-properties-and-entities-from-Alert-5\"><span class=\"toc-item-num\">5&nbsp;&nbsp;</span>Extract properties and entities from Alert</a></span></li><li><span><a href=\"#Entity-Graph\" data-toc-modified-id=\"Entity-Graph-6\"><span class=\"toc-item-num\">6&nbsp;&nbsp;</span>Entity Graph</a></span></li><li><span><a href=\"#Related-Alerts\" data-toc-modified-id=\"Related-Alerts-7\"><span class=\"toc-item-num\">7&nbsp;&nbsp;</span>Related Alerts</a></span><ul class=\"toc-item\"><li><span><a href=\"#Show-these-related-alerts-on-a-graph\" data-toc-modified-id=\"Show-these-related-alerts-on-a-graph-7.1\"><span class=\"toc-item-num\">7.1&nbsp;&nbsp;</span>Show these related alerts on a graph</a></span></li><li><span><a href=\"#Browse-List-of-Related-Alerts\" data-toc-modified-id=\"Browse-List-of-Related-Alerts-7.2\"><span class=\"toc-item-num\">7.2&nbsp;&nbsp;</span>Browse List of Related Alerts</a></span></li></ul></li><li><span><a href=\"#Get-Process-Tree\" data-toc-modified-id=\"Get-Process-Tree-8\"><span class=\"toc-item-num\">8&nbsp;&nbsp;</span>Get Process Tree</a></span><ul class=\"toc-item\"><li><span><a href=\"#Process-Time-Line\" data-toc-modified-id=\"Process-Time-Line-8.1\"><span class=\"toc-item-num\">8.1&nbsp;&nbsp;</span>Process Time Line</a></span></li></ul></li><li><span><a href=\"#Other-Processes-on-Host---Clustering\" data-toc-modified-id=\"Other-Processes-on-Host---Clustering-9\"><span class=\"toc-item-num\">9&nbsp;&nbsp;</span>Other Processes on Host - Clustering</a></span><ul class=\"toc-item\"><li><span><a href=\"#Clustered-Processes\" data-toc-modified-id=\"Clustered-Processes-9.1\"><span class=\"toc-item-num\">9.1&nbsp;&nbsp;</span>Clustered Processes</a></span></li><li><span><a href=\"#Variability-in-Command-Lines-and-Process-Names\" data-toc-modified-id=\"Variability-in-Command-Lines-and-Process-Names-9.2\"><span class=\"toc-item-num\">9.2&nbsp;&nbsp;</span>Variability in Command Lines and Process Names</a></span></li><li><span><a href=\"#Time-Line-of--clustered-processes-data-vs.-original-data\" data-toc-modified-id=\"Time-Line-of--clustered-processes-data-vs.-original-data-9.3\"><span class=\"toc-item-num\">9.3&nbsp;&nbsp;</span>Time Line of  clustered processes data vs. original data</a></span></li></ul></li><li><span><a href=\"#Base64-Decode-and-Check-for-IOCs\" data-toc-modified-id=\"Base64-Decode-and-Check-for-IOCs-10\"><span class=\"toc-item-num\">10&nbsp;&nbsp;</span>Base64 Decode and Check for IOCs</a></span><ul class=\"toc-item\"><li><span><a href=\"#IoCs-in-the-entire-data-set\" data-toc-modified-id=\"IoCs-in-the-entire-data-set-10.1\"><span class=\"toc-item-num\">10.1&nbsp;&nbsp;</span>IoCs in the entire data set</a></span></li><li><span><a href=\"#If-any-Base64-encoded-strings,-decode-and-search-for-IoCs-in-the-results.\" data-toc-modified-id=\"If-any-Base64-encoded-strings,-decode-and-search-for-IoCs-in-the-results.-10.2\"><span class=\"toc-item-num\">10.2&nbsp;&nbsp;</span>If any Base64 encoded strings, decode and search for IoCs in the results.</a></span></li></ul></li><li><span><a href=\"#Threat-Intelligence-Lookup\" data-toc-modified-id=\"Threat-Intelligence-Lookup-11\"><span class=\"toc-item-num\">11&nbsp;&nbsp;</span>Threat Intelligence Lookup</a></span></li><li><span><a href=\"#Alert-command-line---Occurrence-on-other-hosts-in-workspace\" data-toc-modified-id=\"Alert-command-line---Occurrence-on-other-hosts-in-workspace-12\"><span class=\"toc-item-num\">12&nbsp;&nbsp;</span>Alert command line - Occurrence on other hosts in workspace</a></span></li><li><span><a href=\"#Host-Logons\" data-toc-modified-id=\"Host-Logons-13\"><span class=\"toc-item-num\">13&nbsp;&nbsp;</span>Host Logons</a></span><ul class=\"toc-item\"><li><span><a href=\"#Alert-Logon-Account\" data-toc-modified-id=\"Alert-Logon-Account-13.1\"><span class=\"toc-item-num\">13.1&nbsp;&nbsp;</span>Alert Logon Account</a></span></li><li><span><a href=\"#All-Host-Logons\" data-toc-modified-id=\"All-Host-Logons-13.2\"><span class=\"toc-item-num\">13.2&nbsp;&nbsp;</span>All Host Logons</a></span><ul class=\"toc-item\"><li><span><a href=\"#Highest-and-lowest-number-of-logon-types-by-Account\" data-toc-modified-id=\"Highest-and-lowest-number-of-logon-types-by-Account-13.2.1\"><span class=\"toc-item-num\">13.2.1&nbsp;&nbsp;</span>Highest and lowest number of logon types by Account</a></span></li></ul></li></ul></li><li><span><a href=\"#Failed-Logons\" data-toc-modified-id=\"Failed-Logons-14\"><span class=\"toc-item-num\">14&nbsp;&nbsp;</span>Failed Logons</a></span></li><li><span><a href=\"#Appendices\" data-toc-modified-id=\"Appendices-15\"><span class=\"toc-item-num\">15&nbsp;&nbsp;</span>Appendices</a></span><ul class=\"toc-item\"><li><span><a href=\"#Available-DataFrames\" data-toc-modified-id=\"Available-DataFrames-15.1\"><span class=\"toc-item-num\">15.1&nbsp;&nbsp;</span>Available DataFrames</a></span></li><li><span><a href=\"#Saving-Data-to-CSV\" data-toc-modified-id=\"Saving-Data-to-CSV-15.2\"><span class=\"toc-item-num\">15.2&nbsp;&nbsp;</span>Saving Data to CSV</a></span></li><li><span><a href=\"#Saving-Data-to-Excel\" data-toc-modified-id=\"Saving-Data-to-Excel-15.3\"><span class=\"toc-item-num\">15.3&nbsp;&nbsp;</span>Saving Data to Excel</a></span></li></ul></li><li><span><a href=\"#Configuration\" data-toc-modified-id=\"Configuration-16\"><span class=\"toc-item-num\">16&nbsp;&nbsp;</span>Configuration</a></span><ul class=\"toc-item\"><li><span><a href=\"#msticpyconfig.yaml-configuration-File\" data-toc-modified-id=\"msticpyconfig.yaml-configuration-File-16.1\"><span class=\"toc-item-num\">16.1&nbsp;&nbsp;</span><code>msticpyconfig.yaml</code> configuration File</a></span></li></ul></li></ul></div>"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "<a></a>[Contents](#toc)\n",
        "## Hunting Hypothesis\n",
        "Our broad initial hunting hypothesis is that a we have received an alert/indicators involving windows process name which is suspected to be malicious, we will need to hunt from a range of different positions to validate or disprove this hypothesis.\n",
        "\n",
        "Before you start hunting please run the cells in <a>Setup</a> at the bottom of this Notebook."
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "---\n",
        "### Notebook initialization\n",
        "The next cell:\n",
        "- Checks for the correct Python version\n",
        "- Checks versions and optionally installs required packages\n",
        "- Imports the required packages into the notebook\n",
        "- Sets a number of configuration options.\n",
        "\n",
        "This should complete without errors. If you encounter errors or warnings look at the following two notebooks:\n",
        "- [TroubleShootingNotebooks](https://github.com/Azure/Azure-Sentinel-Notebooks/blob/master/TroubleShootingNotebooks.ipynb)\n",
        "- [ConfiguringNotebookEnvironment](https://github.com/Azure/Azure-Sentinel-Notebooks/blob/master/ConfiguringNotebookEnvironment.ipynb)\n",
        "\n",
        "If you are running in the Microsoft Sentinel Notebooks environment (Azure Notebooks or Azure ML) you can run live versions of these notebooks:\n",
        "- [Run TroubleShootingNotebooks](./TroubleShootingNotebooks.ipynb)\n",
        "- [Run ConfiguringNotebookEnvironment](./ConfiguringNotebookEnvironment.ipynb)\n",
        "\n",
        "You may also need to do some additional configuration to successfully use functions such as Threat Intelligence service lookup and Geo IP lookup. \n",
        "There are more details about this in the `ConfiguringNotebookEnvironment` notebook and in these documents:\n",
        "- [msticpy configuration](https://msticpy.readthedocs.io/en/latest/getting_started/msticpyconfig.html)\n",
        "- [Threat intelligence provider configuration](https://msticpy.readthedocs.io/en/latest/data_acquisition/TIProviders.html#configuration-file)\n"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267895261
        }
      },
      "outputs": [],
      "source": [
        "from pathlib import Path\n",
        "from IPython.display import display, HTML, Markdown\n",
        "\n",
        "REQ_PYTHON_VER = \"3.10\"\n",
        "REQ_MSTICPY_VER = \"2.12.0\"\n",
        "REQ_MP_EXTRAS = [\"ml\"]\n",
        "\n",
        "\n",
        "display(HTML(\"<h3>Starting Notebook setup...</h3>\"))\n",
        "\n",
        "# If not using Azure Notebooks, install msticpy with\n",
        "# %pip install msticpy\n",
        "\n",
        "import msticpy as mp\n",
        "additional_packages = [\"seaborn\"]\n",
        "\n",
        "mp.init_notebook(\n",
        "    namespace=globals(),\n",
        "    additional_packages=additional_packages\n",
        ");"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "<a></a>[Contents](#toc)\n",
        "### Get WorkspaceId and Authenticate to Log Analytics \n",
        "<details>\n",
        "    <summary> <u>Details...</u></summary>\n",
        "If you are using user/device authentication, run the following cell. \n",
        "- Click the 'Copy code to clipboard and authenticate' button.\n",
        "- This will pop up an Azure Active Directory authentication dialog (in a new tab or browser window). The device code will have been copied to the clipboard. \n",
        "- Select the text box and paste (Ctrl-V/Cmd-V) the copied value. \n",
        "- You should then be redirected to a user authentication page where you should authenticate with a user account that has permission to query your Log Analytics workspace.\n",
        "\n",
        "Use the following syntax if you are authenticating using an Azure Active Directory AppId and Secret:\n",
        "```\n",
        "%kql loganalytics://tenant(aad_tenant).workspace(WORKSPACE_ID).clientid(client_id).clientsecret(client_secret)\n",
        "```\n",
        "instead of\n",
        "```\n",
        "%kql loganalytics://code().workspace(WORKSPACE_ID)\n",
        "```\n",
        "\n",
        "Note: you may occasionally see a JavaScript error displayed at the end of the authentication - you can safely ignore this.<br>\n",
        "On successful authentication you should see a ```popup schema``` button.\n",
        "To find your Workspace Id go to [Log Analytics](https://ms.portal.azure.com/#blade/HubsExtension/Resources/resourceType/Microsoft.OperationalInsights%2Fworkspaces). Look at the workspace properties to find the ID.\n",
        "</details>"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267910617
        }
      },
      "outputs": [],
      "source": [
        "# See if we have a Microsoft Sentinel Workspace defined in our config file.\n",
        "# If not, let the user specify Workspace and Tenant IDs\n",
        "\n",
        "ws_config = mp.WorkspaceConfig()\n",
        "if not ws_config.config_loaded:\n",
        "    ws_config.prompt_for_ws()\n",
        "\n",
        "qry_prov = mp.QueryProvider(data_environment=\"AzureSentinel\")\n",
        "print(\"done\")"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267931673
        }
      },
      "outputs": [],
      "source": [
        "# Authenticate to Microsoft Sentinel workspace\n",
        "qry_prov.connect(ws_config)\n",
        "table_index = qry_prov.schema_tables"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Get List of Alerts\n",
        "\n",
        "We are using an alert as the starting point for this investigation, specify a time range to search for alerts. Once this is set run the following cell to retrieve any alerts in that time window.\n",
        "You can change the time range and re-run the queries until you find the alerts that you want to investigate."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267936202
        }
      },
      "outputs": [],
      "source": [
        "from msticpy import nbwidgets\n",
        "alert_q_times = nbwidgets.QueryTime(\n",
        "    units='hour', max_before=72, max_after=1, before=24\n",
        ")\n",
        "alert_q_times.display()"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267941428
        }
      },
      "outputs": [],
      "source": [
        "alert_list = qry_prov.SecurityAlert.list_alerts(\n",
        "    alert_q_times)\n",
        "alert_counts = qry_prov.SecurityAlert.list_alerts_counts(\n",
        "    alert_q_times)\n",
        "\n",
        "if isinstance(alert_list, pd.DataFrame) and not alert_list.empty:\n",
        "    print(len(alert_counts), ' distinct alert types')\n",
        "    print(len(alert_list), ' distinct alerts')\n",
        "\n",
        "# Display alerts on timeline to aid in visual grouping\n",
        "    nbdisplay.display_timeline(\n",
        "        data=alert_list, source_columns=[\"AlertName\", 'CompromisedEntity'], title=\"Alerts over time\", height=300, color=\"red\")\n",
        "    display(alert_counts.head(10)) # remove '.head(10)'' to see the full list grouped by AlertName\n",
        "else:\n",
        "    display(Markdown('No alerts found.'))"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Choose Alert to Investigate\n",
        "To focus the investigation select an alert from a list of retrieved alerts.\n",
        "\n",
        "As you select an alert, the main properties will be shown below the list.\n",
        "\n",
        "Use the filter box to narrow down your search to any substring in the AlertName."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618267944699
        }
      },
      "outputs": [],
      "source": [
        "pd.set_option(\"display.html.table_schema\", False)\n",
        "get_alert = None\n",
        "alert_select = nbwidgets.SelectAlert(alerts=alert_list, action=nbdisplay.format_alert)\n",
        "alert_select.display()"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Extract properties and entities from Alert\n",
        "In order to pivot to data related to the selected security alert we need to identify key data points in the selected alert. This section extracts the alert information and entities into a SecurityAlert object allowing us to query the properties more reliably. \n",
        "\n",
        "Properties in this object will be used to automatically provide parameters for queries and UI elements.\n",
        "Subsequent queries will use properties like the host name and derived properties such as the OS family (Linux or Windows) to adapt the query. Query time selectors like the one above will also default to an origin time that matches the alert selected.\n",
        "\n",
        "The alert view below shows all of the main properties of the alert plus the extended property dictionary (if any) and JSON representations of the Entity."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270339475
        }
      },
      "outputs": [],
      "source": [
        "# Extract entities and properties into a SecurityAlert class\n",
        "from msticpy.vis import nbdisplay\n",
        "from msticpy.nbtools.security_alert import SecurityAlert\n",
        "from msticpy.nbtools import security_alert_graph\n",
        "\n",
        "if alert_select is None or alert_select.selected_alert is None:\n",
        "    raise ValueError(\"Please select an alert before executing remaining cells.\")\n",
        "else:\n",
        "    security_alert = SecurityAlert(alert_select.selected_alert)\n",
        "\n",
        "nbdisplay.display_alert(security_alert, show_entities=True)"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Entity Graph\n",
        "Depending on the type of alert there may be one or more entities attached as properties. Entities are key indicators that we can pivot on during our investigation, such as Host, Account, IpAddress, Process, etc. - essentially the 'nouns' of security investigation. \n",
        "Entities are often related to other entities - for example a process will usually have a related file entity (the process image) and an Account entity (the context in which the process was running). Endpoint alerts typically always have a host entity (which could be a physical or virtual machine). In order to more effectively understand the links between related entities we can plot them as a graph."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270347583
        },
        "jupyter": {
          "outputs_hidden": false,
          "source_hidden": false
        },
        "nteract": {
          "transient": {
            "deleting": false
          }
        }
      },
      "outputs": [],
      "source": [
        "alertentity_graph = security_alert_graph.create_alert_graph(security_alert)\n",
        "nbdisplay.draw_alert_entity_graph(alertentity_graph, width=15)"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "\n",
        "## Related Alerts\n",
        "For certain entities in the alert we can search for other alerts that have that entity in common. Currently this pivot supports alerts with the same Host, Account or Process. \n",
        "\n",
        "**Notes:**\n",
        "- Some alert types do not include all of these entity types.\n",
        "- The original alert will be included in the \"Related Alerts\" set if it occurs within the query time boundary set below.\n",
        "\n",
        "In order to more effectively identify related alerts the query time boundaries can be adjusted to encompass a longer time frame."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270363529
        }
      },
      "outputs": [],
      "source": [
        "# set the origin time to the time of our alert\n",
        "query_times = nbwidgets.QueryTime(units='day', origin_time=security_alert.TimeGenerated,\n",
        "                            max_before=28, max_after=1, before=5)\n",
        "query_times.display()"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270368602
        }
      },
      "outputs": [],
      "source": [
        "if not security_alert.primary_host:\n",
        "    md_warn('Related alerts is not yet supported for alerts that are not host-based')\n",
        "    related_alerts = None\n",
        "else:\n",
        "    hostname = security_alert.hostname\n",
        "    if not hostname and \"AzureID\" in security_alert.primary_host:\n",
        "        hostname = security_alert.primary_host.AzureID.split(\"/\")[-1]\n",
        "    related_alerts = qry_prov.SecurityAlert.list_related_alerts(query_times, security_alert, host_name=hostname)\n",
        "\n",
        "\n",
        "    if related_alerts is not None and not related_alerts.empty:\n",
        "        host_alert_items = related_alerts\\\n",
        "            .query('host_match == @True')[['AlertType', 'StartTimeUtc']]\\\n",
        "            .groupby('AlertType').StartTimeUtc.agg('count').to_dict()\n",
        "        acct_alert_items = related_alerts\\\n",
        "            .query('acct_match == @True')[['AlertType', 'StartTimeUtc']]\\\n",
        "            .groupby('AlertType').StartTimeUtc.agg('count').to_dict()\n",
        "        proc_alert_items = related_alerts\\\n",
        "            .query('proc_match == @True')[['AlertType', 'StartTimeUtc']]\\\n",
        "            .groupby('AlertType').StartTimeUtc.agg('count').to_dict()\n",
        "\n",
        "        def print_related_alerts(alertDict, entityType, entityName):\n",
        "            if len(alertDict) > 0:\n",
        "                print('Found {} different alert types related to this {} (\\'{}\\')'\n",
        "                      .format(len(alertDict), entityType, entityName))\n",
        "                for (k,v) in alertDict.items():\n",
        "                    print('    {}, Count of alerts: {}'.format(k, v))\n",
        "            else:\n",
        "                print('No alerts for {} entity \\'{}\\''.format(entityType, entityName))\n",
        "\n",
        "        print_related_alerts(host_alert_items, 'host', security_alert.hostname)\n",
        "        print_related_alerts(acct_alert_items, 'account',\n",
        "                             security_alert.primary_account.qualified_name\n",
        "                             if security_alert.primary_account\n",
        "                             else None)\n",
        "        print_related_alerts(proc_alert_items, 'process',\n",
        "                             security_alert.primary_process.ProcessFilePath\n",
        "                             if security_alert.primary_process\n",
        "                             else None)\n",
        "        nbdisplay.display_timeline(data=related_alerts, source_columns = ['AlertName'], title='Alerts', height=100)\n",
        "    else:\n",
        "        md('No related alerts found.', styles=[\"bold\",\"green\"])"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Show these related alerts on a graph\n",
        "To see the how these alerts relate to our original alert, and how these new alerts relate to each other we can graph them."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270371574
        }
      },
      "outputs": [],
      "source": [
        "# Draw a graph of this (add to entity graph)\n",
        "\n",
        "if related_alerts is not None and not related_alerts.empty:\n",
        "    rel_alert_graph = security_alert_graph.add_related_alerts(related_alerts=related_alerts,\n",
        "                                             alertgraph=alertentity_graph)\n",
        "    nbdisplay.draw_alert_entity_graph(rel_alert_graph, width=15)\n",
        "else:\n",
        "    md('No related alerts found.', styles=[\"bold\",\"green\"])"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Browse List of Related Alerts\n",
        "Once we have understood how these alerts related to each other, we can view the details of each new, related alert."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270381877
        }
      },
      "outputs": [],
      "source": [
        "def disp_full_alert(alert):\n",
        "    global related_alert\n",
        "    related_alert = SecurityAlert(alert)\n",
        "    return nbdisplay.format_alert(related_alert, show_entities=True)\n",
        "\n",
        "if related_alerts is not None and not related_alerts.empty:\n",
        "    related_alerts['CompromisedEntity'] = related_alerts['Computer']\n",
        "    print('Selected alert is available as \\'related_alert\\' variable.')\n",
        "    rel_alert_select = nbwidgets.SelectAlert(alerts=related_alerts, action=disp_full_alert)\n",
        "    rel_alert_select.display()\n",
        "else:\n",
        "    md('No related alerts found.', styles=[\"bold\",\"green\"])"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Get Process Tree\n",
        "If the alert has a process entity this section tries to retrieve the entire process tree to which that process belongs.\n",
        "\n",
        "Notes:\n",
        "- The alert must have a process entity\n",
        "- Only processes started within the query time boundary will be included\n",
        "- Ancestor and descented processes are retrieved to two levels (i.e. the parent and grandparent of the alert process plus any child and grandchild processes).\n",
        "- Sibling processes are the processes that share the same parent as the alert process\n",
        "- This can be a long-running query, especially if a wide time window is used! Caveat Emptor!\n",
        "\n",
        "The source (alert) process is shown in red.\n",
        "\n",
        "What's shown for each process:\n",
        "- Each process line is indented according to its position in the tree hierarchy\n",
        "- Top line fields:\n",
        "  - \\[relationship to source process:lev# - where # is the hops away from the source process\\]\n",
        "  - Process creation date-time (UTC)\n",
        "  - Process Image path\n",
        "  - PID - Process Id\n",
        "  - SubjSess - the session Id of the process spawning the new process\n",
        "  - TargSess - the new session Id if the process is launched in another context/session. If 0/0x0 then the process is launched in the same session as its parent\n",
        "- Second line fields:\n",
        "  - Process command line\n",
        "  - Account - name of the account context in which the process is running"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270391776
        }
      },
      "outputs": [],
      "source": [
        "# set the origin time to the time of our alert\n",
        "query_times = nbwidgets.QueryTime(units='minute', origin_time=security_alert.origin_time)\n",
        "query_times.display()"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270720441
        }
      },
      "outputs": [],
      "source": [
        "if security_alert.data_family.name != \"WindowsSecurity\":\n",
        "    raise ValueError('The remainder of this notebook currently only supports Windows. '\n",
        "                     'Linux support is in development but not yet implemented.')\n",
        "\n",
        "if (security_alert.primary_process):\n",
        "    # run the query\n",
        "    process_tree = qry_prov.WindowsSecurity.list_host_processes(\n",
        "        query_times,\n",
        "        host_name=security_alert.primary_host.HostName,\n",
        "    )\n",
        "\n",
        "    if process_tree is not None and not process_tree.empty:\n",
        "        # Print out the text view of the process tree\n",
        "        nbdisplay.display_process_tree(process_tree)\n",
        "    else:\n",
        "        md_warn('No processes were returned so cannot obtain a process tree.')\n",
        "        display(Markdown('Skip to [Other Processes](#process_clustering) later in the notebook to retrieve all processes'))\n",
        "else:\n",
        "    md_warn('This alert has no process entity so cannot obtain a process tree.')\n",
        "    display(Markdown('Skip to [Other Processes](#process_clustering) later in the notebook to retrieve all processes'))\n",
        "    process_tree = None"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Process Time Line\n",
        "As well as seeing the processes involved in a tree we want to see the chronology of this process execution. This shows each process in the process tree on a time line view.\n",
        "If a large number of processes are involved in this process tree it may take some time to display this time line graphic."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270725033
        }
      },
      "outputs": [],
      "source": [
        "# Show timeline of events\n",
        "if process_tree is not None and not process_tree.empty:\n",
        "    nbdisplay.display_timeline(data=process_tree, alert=security_alert,\n",
        "                            title='Alert Process Session', height=250)\n",
        "else:\n",
        "    md_warn('This alert has no process entity so cannot obtain a process tree.')\n",
        "    display(Markdown('Skip to [Other Processes](#process_clustering) later in the notebook to retrieve all processes'))\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Other Processes on Host - Clustering\n",
        "Sometimes you don't have a source process from which to build our investigation. Other times it's just useful to see what other process activity is occurring on the host. This section retrieves all processes on the host within the time bounds\n",
        "set in the query times widget.\n",
        "\n",
        "If you want to view the raw details of this process data display the *processes_on_host* dataframe.\n",
        "\n",
        "In order to more effectively analyze this process data we can cluster processes into distinct process clusters.\n",
        "To do this we process the raw event list output to extract a few features that render strings (such as commandline)into numerical values. The default below uses the following features:\n",
        "- commandLineTokensFull - this is a count of common delimiters in the commandline \n",
        "  (given by this regex r'[\\s\\-\\\\/\\.,\"\\'|&amp;:;%$()]'). The aim of this is to capture the commandline structure while ignoring variations on what is essentially the same pattern (e.g. temporary path GUIDs, target IP or host names, etc.)\n",
        "- pathScore - this sums the ordinal (character) value of each character in the path (so /bin/bash and /bin/bosh would have similar scores).\n",
        "- isSystemSession - 1 if this is a root/system session, 0 if anything else.\n",
        "\n",
        "Then we run a clustering algorithm (DBScan in this case) on the process list. The result groups similar (noisy) processes together and leaves unique process patterns as single-member clusters."
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Clustered Processes"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270900530
        }
      },
      "outputs": [],
      "source": [
        "from msticpy.analysis.eventcluster import dbcluster_events, add_process_features\n",
        "from tqdm.notebook import tqdm\n",
        "tqdm.pandas(desc=\"progress\")\n",
        "\n",
        "processes_on_host = None\n",
        "if security_alert.primary_host:\n",
        "    md(\"Querying data...\")\n",
        "    processes_on_host = qry_prov.WindowsSecurity.list_host_processes(\n",
        "        query_times,\n",
        "        security_alert,\n",
        "        host_name=security_alert.primary_host.HostName\n",
        "    )\n",
        "\n",
        "    if processes_on_host is not None and not processes_on_host.empty:\n",
        "        md(\"Extracting features...\")\n",
        "        feature_procs = add_process_features(input_frame=processes_on_host,\n",
        "                                             path_separator=security_alert.path_separator)\n",
        "\n",
        "        # you might need to play around with the max_cluster_distance parameter.\n",
        "        # decreasing this gives more clusters.\n",
        "        md(\"Clustering data...\")\n",
        "        (clus_events, dbcluster, x_data) = dbcluster_events(data=feature_procs,\n",
        "                                                            cluster_columns=['commandlineTokensFull',\n",
        "                                                                             'pathScore',\n",
        "                                                                             'isSystemSession'],\n",
        "                                                            max_cluster_distance=0.0001)\n",
        "        print('Number of input events:', len(feature_procs))\n",
        "        print('Number of clustered events:', len(clus_events))\n",
        "        height = int(len(clus_events[clus_events['ClusterSize'] > 1]) / 4)\n",
        "        clus_events[['ClusterSize', 'processName']][clus_events['ClusterSize'] > 1].plot.barh(x='processName',\n",
        "                                                                                             title='Process names with Cluster > 1',\n",
        "                                                                                             figsize=(6, height));\n",
        "if processes_on_host is None or processes_on_host.empty:\n",
        "    md(\n",
        "        \"Unable to obtain any processes for this host. \"\n",
        "        + \"This feature is currently only supported for Windows hosts.\",\n",
        "        styles=[\"blue\",\"bold\"]\n",
        "    )\n",
        "    md(\n",
        "        \"If this is a Windows host skip to <i>Host Logons</i> \"\n",
        "        + \"later in the notebook to examine logon events.\",\n",
        "        styles=[\"bold\",\"large\"]\n",
        "    )"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Variability in Command Lines and Process Names\n",
        "In this section we display a number of charts highlighting the variability of command lines and processes paths associated with each process. \n",
        "\n",
        "The top chart shows the variability of command line content for a given process name. The wider the box, the more instances were found with different command line structure. For certain processes such as cmd.exe or powershell.exe a wide variability in command lines could be expected, however with other processes this could be considered abnormal.\n",
        "\n",
        "Note, the 'structure' in this case is measured by the number of tokens or delimiters in the command line and does not look at content differences. This is done so that commonly varying instances of the same command line are grouped together.<br>\n",
        "For example `updatepatch host1.mydom.com` and `updatepatch host2.mydom.com` will be grouped together.\n",
        "\n",
        "\n",
        "The second graph shows processes by variation in the full path associated with the process. This does compare content so `c:\\windows\\system32\\net.exe` and `e:\\windows\\system32\\net.exe` are treated as distinct. You would normally not expect to see any variability in this chart unless you have multiple copies of the same name executable or an executable is trying masquerade as another well-known binary."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831057717
        }
      },
      "outputs": [],
      "source": [
        "# Looking at the variability of commandlines and process image paths\n",
        "import seaborn as sns\n",
        "sns.set(style=\"darkgrid\")\n",
        "\n",
        "if processes_on_host is not None and not processes_on_host.empty:\n",
        "    proc_plot = sns.catplot(y=\"processName\", x=\"commandlineTokensFull\",\n",
        "                            data=feature_procs.sort_values('processName'),\n",
        "                            kind='box', height=10)\n",
        "    proc_plot.fig.suptitle('Variability of Commandline Tokens', x=1, y=1)\n",
        "\n",
        "    proc_plot = sns.catplot(y=\"processName\", x=\"pathLogScore\",\n",
        "                            data=feature_procs.sort_values('processName'),\n",
        "                            kind='box', height=10, hue='isSystemSession')\n",
        "    proc_plot.fig.suptitle('Variability of Path', x=1, y=1);"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831153894
        }
      },
      "outputs": [],
      "source": [
        "if \"clus_events\" in locals() and not clus_events.empty:\n",
        "    cols = [\n",
        "        \"TimeGenerated\",\n",
        "        \"LastEventTime\",\n",
        "        \"NewProcessName\",\n",
        "        \"CommandLine\",\n",
        "        \"ClusterSize\",\n",
        "        \"commandlineTokensFull\",\n",
        "        \"pathScore\",\n",
        "        \"isSystemSession\",\n",
        "    ]\n",
        "    display(clus_events.sort_values(\"TimeGenerated\")[cols])"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831211249
        }
      },
      "outputs": [],
      "source": [
        "# Look at clusters for individual process names\n",
        "def view_cluster(exe_name):\n",
        "    display(clus_events[['ClusterSize', 'processName', 'CommandLine', 'ClusterId']][clus_events['processName'] == exe_name])\n",
        "\n",
        "display(Markdown('You can view the cluster members for individual processes'\n",
        "                 'by inserting a new cell and entering:<br>'\n",
        "                 '`view_cluster(process_name)`<br></div>'\n",
        "                 'where process_name is the unqualified process binary. E.g<br>'\n",
        "                 '`view_cluster(\"reg.exe\")`'))"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Time Line of  clustered processes data vs. original data"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831217785
        }
      },
      "outputs": [],
      "source": [
        "# Show timeline of events - clustered events\n",
        "if 'clus_events' in locals() and not clus_events.empty:\n",
        "    nbdisplay.display_timeline(data=clus_events,\n",
        "                            overlay_data=processes_on_host,\n",
        "                            alert=security_alert,\n",
        "                            title='Distinct Host Processes (bottom) and All Proceses (top)')"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "<a></a>[Contents](#toc)\n",
        "## Base64 Decode and Check for IOCs\n",
        "This section looks for Indicators of Compromise (IoC) within the data sets passed to it.\n",
        "\n",
        "The first section looks at the command line for the process related to our original alert (if any). It also looks for Base64 encoded strings within the data - this is a common way of hiding attacker intent. It attempts to decode any strings that look like Base64. Additionally, if the Base64 decode operation returns any items that look like a Base64 encoded string or file, a gzipped binary sequence, a zipped or tar archive, it will attempt to extract the contents before searching for potentially interesting items."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270930171
        }
      },
      "outputs": [],
      "source": [
        "process = security_alert.primary_process\n",
        "ioc_extractor = IoCExtract()\n",
        "\n",
        "if process and process[\"CommandLine\"]:\n",
        "    # if nothing is decoded this just returns the input string unchanged\n",
        "    base64_dec_str, _ = base64.unpack_items(input_string=process[\"CommandLine\"])\n",
        "    if base64_dec_str and '<decoded' in base64_dec_str:\n",
        "        print('Base64 encoded items found.')\n",
        "        print(base64_dec_str)\n",
        "\n",
        "    # any IoCs in the string?\n",
        "    iocs_found = ioc_extractor.extract(base64_dec_str)\n",
        "\n",
        "    if iocs_found:\n",
        "        print('\\nPotential IoCs found in alert process:')\n",
        "        display(iocs_found)\n",
        "    else:\n",
        "        print('No IoCs found in alert process:')\n",
        "else:\n",
        "    print('No process command line available in selected alert.')\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### IoCs in the entire data set\n",
        "If we have a process tree or other elements that contain command lines we also want to attempt to extract IoCs from these data sets."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270944674
        }
      },
      "outputs": [],
      "source": [
        "ioc_extractor = IoCExtract()\n",
        "\n",
        "source_processes = None\n",
        "# if process tree is populated we use that preferentially\n",
        "try:\n",
        "    if not process_tree.empty:\n",
        "        source_processes = process_tree\n",
        "except (NameError, AttributeError):\n",
        "    pass\n",
        "\n",
        "# If not, use the clustered events from the all sessions\n",
        "try:\n",
        "    if source_processes is None and not clus_events.empty:\n",
        "        source_processes = clus_events\n",
        "except (NameError, AttributeError):\n",
        "    pass\n",
        "\n",
        "if source_processes is not None and not source_processes.empty:\n",
        "    ioc_df = ioc_extractor.extract(data=source_processes,\n",
        "                                   columns=['CommandLine'],\n",
        "                                   ioc_types=['ipv4', 'ipv6', 'dns', 'url',\n",
        "                                              'md5_hash', 'sha1_hash', 'sha256_hash'])\n",
        "    if len(ioc_df):\n",
        "        display(HTML(\"<h3>IoC patterns found in process tree.</h3>\"))\n",
        "        display(ioc_df)\n",
        "else:\n",
        "    ioc_df = None"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### If any Base64 encoded strings, decode and search for IoCs in the results.\n",
        "For simple strings the Base64 decoded output is straightforward. However it is not uncommon to see nested encodings therefore we want to try to extract and decode these nested elements as well."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618270958621
        }
      },
      "outputs": [],
      "source": [
        "if source_processes is not None:\n",
        "    dec_df = base64.unpack_items(data=source_processes, column='CommandLine')\n",
        "\n",
        "if source_processes is not None and (dec_df is not None and not dec_df.empty):\n",
        "    display(HTML(\"<h3>Decoded base 64 command lines</h3>\"))\n",
        "    md_warn(\"Some binary patterns may be decodable as unicode strings\")\n",
        "    display(dec_df[['full_decoded_string', 'original_string', 'decoded_string', 'input_bytes', 'file_hashes']])\n",
        "\n",
        "    ioc_dec_df = ioc_extractor.extract(data=dec_df, columns=['full_decoded_string'])\n",
        "    if len(ioc_dec_df):\n",
        "        display(HTML(\"<h3>IoC patterns found in base 64 decoded data</h3>\"))\n",
        "        display(ioc_dec_df)\n",
        "        if ioc_df is not None:\n",
        "            ioc_df = ioc_df.append(ioc_dec_df ,ignore_index=True)\n",
        "        else:\n",
        "            ioc_df = ioc_dec_df\n",
        "else:\n",
        "    print(\"No base64 encodings found.\")"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "hidden": true
      },
      "source": [
        "## Threat Intelligence Lookup\n",
        "Now that we have identified a number of IoCs we want to check to see if they are associated with known mallicious activity. To do this we will query three different Threat Intelligence providers to see if we get results.\n",
        "\n",
        "We will be using:\n",
        "- VirusTotal https://www.virustotal.com/.\n",
        "- Alienware OTX https://otx.alienvault.com/\n",
        "- IBM X-Force https://exchange.xforce.ibmcloud.com/\n",
        "\n",
        "If you do not have an API key for any of these providers simply remove their name from the providers list in our lookup_iocs command."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271001116
        }
      },
      "outputs": [],
      "source": [
        "from msticpy.sectools.tiproviders.ti_provider_base import TISeverity\n",
        "\n",
        "def ti_check_ser_sev(data, threshold):\n",
        "    threshold = TISeverity.parse(threshold)\n",
        "    return data.apply(lambda x: TISeverity.parse(x) >= threshold)\n",
        "\n",
        "tilookups = TILookup()\n",
        "if ioc_df is not None and not ioc_df.empty:\n",
        "    ti_results = tilookups.lookup_iocs(data=ioc_df, obs_col='Observable', ioc_type_col='IoCType')\n",
        "    if not ti_results[ti_check_ser_sev(ti_results['Severity'], 1)].empty:\n",
        "        md(\"Positive TI Results:\",styles=[\"bold\",\"red\",\"large\"])\n",
        "        display(ti_results[ti_check_ser_sev(ti_results['Severity'], 1)])\n",
        "    else:\n",
        "        md(\"No postive matches found in threat intelligence\",styles=[\"bold\",\"green\"])\n",
        "else:\n",
        "    md_warn(\"No IOCs to lookup\")"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Alert command line - Occurrence on other hosts in workspace\n",
        "Understanding where else a command line is being run in an environment can give us a good idea of the scope of a security incident, or help us determine whether activity is malicious or expected.\n",
        "\n",
        "To get a sense of whether the alert process is something that is occuring on other hosts, run this section."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831384220
        }
      },
      "outputs": [],
      "source": [
        "# set the origin time to the time of our alert\n",
        "query_times = nbwidgets.QueryTime(units='day', before=5, max_before=20,\n",
        "                            after=1, max_after=10,\n",
        "                            origin_time=security_alert.origin_time)\n",
        "query_times.display()"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1617831392254
        }
      },
      "outputs": [],
      "source": [
        "# This query needs a commandline parameter which isn't supplied\n",
        "# by default from the the alert\n",
        "# - so extract and escape this from the process\n",
        "proc_match_in_ws = None\n",
        "\n",
        "if not security_alert.primary_process:\n",
        "    md_warn('This alert has no process entity. This section is not applicable.')\n",
        "elif not security_alert.primary_process.CommandLine:\n",
        "    md_warn('This alert process entity has no commandline. This section is not applicable.')\n",
        "\n",
        "elif security_alert.primary_process:\n",
        "    commandline = security_alert.primary_process.CommandLine\n",
        "    commandline = utils.escape_windows_path(commandline)\n",
        "    commandline = commandline.replace('\"',\"'\")\n",
        "    process = security_alert.primary_process.ProcessName\n",
        "    if not process:\n",
        "        raise ValueError(\"No process name found in selected alert\")\n",
        "    process = utils.escape_windows_path(process)\n",
        "    process = process.replace('\"',\"'\")\n",
        "    md(f\"Command Line: '{commandline}'\", styles=[\"bold\"])\n",
        "\n",
        "    if commandline.strip():\n",
        "        proc_match_in_ws = qry_prov.WindowsSecurity.list_hosts_matching_commandline(start=query_times.start, end=query_times.end, process_name=process,\n",
        "                                                              commandline=commandline)\n",
        "\n",
        "    else:\n",
        "        md('process has empty commandline')\n",
        "# Check the results\n",
        "if proc_match_in_ws is None or proc_match_in_ws.empty:\n",
        "    md('No proceses with matching commandline found in on other hosts in workspace', styles=[\"bold\",\"blue\"])\n",
        "    md(f'between: {query_times.start} and {query_times.end}')\n",
        "else:\n",
        "    hosts = proc_match_in_ws['Computer'].drop_duplicates().shape[0]\n",
        "    processes = proc_match_in_ws.shape[0]\n",
        "    md('{numprocesses} proceses with matching commandline found on {numhosts} hosts in workspace'\\\n",
        "         .format(numprocesses=processes, numhosts=hosts))\n",
        "    md(f'between: {query_times.start} and {query_times.end}')\n",
        "    md('To examine these execute the dataframe \\'{}\\' in a new cell'.format('proc_match_in_ws'))\n",
        "    md(proc_match_in_ws[['TimeCreatedUtc','Computer', 'NewProcessName', 'CommandLine']].head())"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "If at this point you wish to investigate a particular host in detail you can use the cells below or you can switch to our Host Investigation Notebooks that provide a deep dive capability for Windows and Linux hosts.\n",
        "\n",
        "## Host Logons\n",
        "This section retrieves the logon events on the host in the alert.\n",
        "\n",
        "You may want to use the query times to search over a broader range than the default."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271013952
        }
      },
      "outputs": [],
      "source": [
        "# set the origin time to the time of our alert\n",
        "query_times = nbwidgets.QueryTime(units='day', origin_time=security_alert.origin_time,\n",
        "                           before=1, after=0, max_before=20, max_after=1)\n",
        "query_times.display()"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "hidden": true
      },
      "source": [
        "If you wish to investigate a specific host in detail you can use the cells below or switch to our Account investigation notebook. \n",
        "\n",
        "### Alert Logon Account\n",
        "This returns the account associated with the alert being investigated."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271020457
        }
      },
      "outputs": [],
      "source": [
        "logon_id = security_alert.get_logon_id()\n",
        "\n",
        "if logon_id:\n",
        "    if logon_id in [\"0x3e7\", \"0X3E7\", \"-1\", -1]:\n",
        "        print(\n",
        "            \"Cannot retrieve single logon event for system logon id \"\n",
        "            \"- please continue with All Host Logons below.\"\n",
        "        )\n",
        "    else:\n",
        "        logon_event = qry_prov.WindowsSecurity.get_host_logon(\n",
        "            provs=[query_times, security_alert],\n",
        "            host_name=security_alert.ExtendedProperties[\"Compromised Host\"],\n",
        "            start=query_times.start,\n",
        "            end=query_times.end,\n",
        "            logon_session_id=sess_id,\n",
        "        )\n",
        "        nbdisplay.display_logon_data(logon_event, security_alert)\n",
        "else:\n",
        "    print(\n",
        "        \"No account entity in the source alert or the primary account had no logonId value set.\"\n",
        "    )"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### All Host Logons\n",
        "Since the number of logon events may be large and, in the case of system logons, very repetitive, we use clustering to try to identity logons with unique characteristics.\n",
        "\n",
        "In this case we use the numeric score of the account name and the logon type (i.e. interactive, service, etc.). The results of the clustered logons are shown below along with a more detailed, readable printout of the logon event information. The data here will vary depending on whether this is a Windows or Linux host."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271027006
        }
      },
      "outputs": [],
      "source": [
        "from msticpy.sectools.eventcluster import (\n",
        "    dbcluster_events,\n",
        "    add_process_features,\n",
        "    char_ord_score,\n",
        ")\n",
        "import warnings\n",
        "\n",
        "if security_alert.primary_host:\n",
        "    md(\"Querying data...\")\n",
        "    host_logons = qry_prov.WindowsSecurity.list_host_logons(\n",
        "        query_times, security_alert, host_name=security_alert.primary_host.HostName\n",
        "    )\n",
        "\n",
        "    with warnings.catch_warnings():\n",
        "        warnings.simplefilter(action=\"ignore\")\n",
        "        host_logons_time = (\n",
        "            host_logons.astype({\"LogonType\": \"int32\"})\n",
        "            .merge(\n",
        "                right=pd.Series(data=nbdisplay._WIN_LOGON_TYPE_MAP, name=\"LogonTypeDesc\"),\n",
        "                left_on=\"LogonType\",\n",
        "                right_index=True,\n",
        "            )\n",
        "            .set_index(\"TimeGenerated\")[[\"LogonTypeDesc\"]]\n",
        "            .groupby([\"LogonTypeDesc\"])\n",
        "            .resample(\"10T\")\n",
        "            .count()\n",
        "            .rename(columns={\"LogonTypeDesc\": \"Count\"})\n",
        "            .reset_index()\n",
        "        )\n",
        "    fig, ax = plt.subplots()\n",
        "    for l_type, logon_group in host_logons_time.groupby(\"LogonTypeDesc\"):\n",
        "        logon_group.plot.line(\n",
        "            x=\"TimeGenerated\",\n",
        "            y=\"Count\",\n",
        "            label=l_type,\n",
        "            title=\"Number of logons by type\",\n",
        "            ax=ax,\n",
        "            figsize=(15, 10)\n",
        "        )\n",
        "else:\n",
        "    host_logons = None\n",
        "    md(\"No data available - alert has no host entity.\")\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "#### Highest and lowest number of logon types by Account"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271130347
        }
      },
      "outputs": [],
      "source": [
        "if host_logons is not None and not host_logons.empty:\n",
        "    display(\n",
        "        host_logons[[\"Account\", \"LogonType\", \"EventID\"]]\n",
        "        .astype({'LogonType': 'int32'})\n",
        "        .merge(right=pd.Series(data=nbdisplay._WIN_LOGON_TYPE_MAP, name=\"LogonTypeDesc\"),\n",
        "            left_on=\"LogonType\", right_index=True)\n",
        "        .drop(columns=\"LogonType\")\n",
        "        .groupby([\"Account\", \"LogonTypeDesc\"])\n",
        "        .count()\n",
        "        .unstack()\n",
        "        .rename(columns={\"EventID\": \"LogonCount\"})\n",
        "        .fillna(0)\n",
        "        .style\n",
        "        .background_gradient(cmap=\"viridis\", low=0.5, high=0)\n",
        "        .format(\"{0:0>3.0f}\")\n",
        "    )"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "hidden": true
      },
      "source": [
        "## Failed Logons\n",
        "Failed logons can provide a valuable source of data for investigation so we also want to look at failed logons during the period of our investigation."
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {
        "gather": {
          "logged": 1618271136584
        },
        "hidden": true
      },
      "outputs": [],
      "source": [
        "if security_alert.primary_host:\n",
        "    failedLogons = qry_prov.WindowsSecurity.list_host_logon_failures(\n",
        "        query_times, security_alert, host_name=security_alert.primary_host.HostName\n",
        "    )\n",
        "\n",
        "else:\n",
        "    md_warn(\"No data available - alert has no host entity.\")\n",
        "    failedLogons = None\n",
        "\n",
        "\n",
        "if failedLogons is None or failedLogons.empty:\n",
        "    md(\n",
        "        f\"\"\"\n",
        "        No logon failures recorded for this host between\n",
        "        {security_alert.StartTimeUtc} and {security_alert.EndTimeUtc}.\n",
        "        \"\"\",\n",
        "        styles=[\"bold\",\"blue\"]\n",
        "    )\n",
        "else:\n",
        "    md(\n",
        "        f\"\"\"Failed Logons observed for the host between\n",
        "        {security_alert.StartTimeUtc} and {security_alert.EndTimeUtc} :\n",
        "        \"\"\",\n",
        "        styles=[\"bold\"]\n",
        "    )\n",
        "    display(failedLogons)"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "hidden": true
      },
      "source": [
        "## Appendices\n",
        "### Available DataFrames"
      ]
    },
    {
      "cell_type": "code",
      "execution_count": null,
      "metadata": {},
      "outputs": [],
      "source": [
        "print('List of current DataFrames in Notebook')\n",
        "print('-' * 50)\n",
        "current_vars = list(locals().keys())\n",
        "for var_name in current_vars:\n",
        "    if isinstance(locals()[var_name], pd.DataFrame) and not var_name.startswith('_'):\n",
        "        print(var_name)"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "### Saving Data to CSV\n",
        "To save the contents of a pandas DataFrame to an CSV\n",
        "use the following syntax\n",
        "```\n",
        "host_logons.to_csv('host_logons.csv')\n",
        "```"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "heading_collapsed": true,
        "tags": [
          "todo"
        ]
      },
      "source": [
        "### Saving Data to Excel\n",
        "To save the contents of a pandas DataFrame to an Excel spreadsheet\n",
        "use the following syntax\n",
        "```\n",
        "writer = pd.ExcelWriter('myWorksheet.xlsx')\n",
        "my_data_frame.to_excel(writer,'Sheet1')\n",
        "writer.save()\n",
        "```"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {},
      "source": [
        "## Configuration\n",
        "\n",
        "### `msticpyconfig.yaml` configuration File\n",
        "You can configure primary and secondary TI providers and any required parameters in the `msticpyconfig.yaml` file. This is read from the current directory or you can set an environment variable (`MSTICPYCONFIG`) pointing to its location.\n",
        "\n",
        "To configure this file see the [ConfigureNotebookEnvironment notebook](https://github.com/Azure/Azure-Sentinel-Notebooks/blob/master/ConfiguringNotebookEnvironment.ipynb)"
      ]
    }
  ],
  "metadata": {
    "hide_input": false,
    "kernel_info": {
      "name": "python310-sdkv2"
    },
    "kernelspec": {
      "display_name": "Python 3.10 - SDK v2",
      "language": "python",
      "name": "python310-sdkv2"
    },
    "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.11.8"
    },
    "latex_envs": {
      "LaTeX_envs_menu_present": true,
      "autoclose": false,
      "autocomplete": true,
      "bibliofile": "biblio.bib",
      "cite_by": "apalike",
      "current_citInitial": 1,
      "eqLabelWithNumbers": true,
      "eqNumInitial": 1,
      "hotkeys": {
        "equation": "Ctrl-E",
        "itemize": "Ctrl-I"
      },
      "labels_anchors": false,
      "latex_user_defs": false,
      "report_style_numbering": false,
      "user_envs_cfg": false
    },
    "microsoft": {
      "host": {
        "AzureML": {
          "notebookHasBeenCompleted": true
        }
      }
    },
    "nteract": {
      "version": "nteract-front-end@1.0.0"
    },
    "toc": {
      "base_numbering": 1,
      "nav_menu": {
        "height": "318.996px",
        "width": "320.994px"
      },
      "number_sections": true,
      "sideBar": true,
      "skip_h1_title": true,
      "title_cell": "Table of Contents",
      "title_sidebar": "Contents",
      "toc_cell": true,
      "toc_position": {
        "height": "calc(100% - 180px)",
        "left": "10px",
        "top": "150px",
        "width": "361px"
      },
      "toc_section_display": true,
      "toc_window_display": true
    },
    "uuid": "3e8f75f2-2a40-4170-b5f5-c5cec2a483c0",
    "varInspector": {
      "cols": {
        "lenName": 16,
        "lenType": 16,
        "lenVar": 40
      },
      "kernels_config": {
        "python": {
          "delete_cmd_postfix": "",
          "delete_cmd_prefix": "del ",
          "library": "var_list.py",
          "varRefreshCmd": "print(var_dic_list())"
        },
        "r": {
          "delete_cmd_postfix": ") ",
          "delete_cmd_prefix": "rm(",
          "library": "var_list.r",
          "varRefreshCmd": "cat(var_dic_list()) "
        }
      },
      "position": {
        "height": "406.193px",
        "left": "1468.4px",
        "right": "20px",
        "top": "120px",
        "width": "456.572px"
      },
      "types_to_exclude": [
        "module",
        "function",
        "builtin_function_or_method",
        "instance",
        "_Feature"
      ],
      "window_display": false
    }
  },
  "nbformat": 4,
  "nbformat_minor": 4
}