syedhassaanahmed

import scala.collection.JavaConversions._
import java.util.HashMap
import com.microsoft.applicationinsights._
import org.apache.spark.sql.streaming._
import org.apache.spark.sql.streaming.StreamingQueryListener._

class AppInsightsListener(instrumentationKey: String, eventName: String) extends StreamingQueryListener {
  val telemetry = new TelemetryClient
  telemetry.getContext.setInstrumentationKey(instrumentationKey)

syedhassaanahmed

#!/bin/bash
set -euo pipefail

SOURCE_KV="<source_key_vault_name>"
DEST_KV="<destination_key_vault_name>"

SOURCE_SECRETS=$(az keyvault secret list --vault-name $SOURCE_KV --query "[].id" -o tsv | cut -d "/" -f5)
DEST_SECRETS=$(az keyvault secret list --vault-name $DEST_KV --query "[].id" -o tsv | cut -d "/" -f5)
MISSING_SECRETS=$(echo "${SOURCE_SECRETS} ${DEST_SECRETS}" | tr ' ' '\n' | sort | uniq -u)

syedhassaanahmed

stages:
- stage: cleanupAcr
  displayName: Cleanup ACR Images for PR
  pool:
    vmImage: ubuntu-latest

  jobs:
  - job: cleanupAcr
    variables:      
      prMergeMessage: 'Merged PR '

syedhassaanahmed

let endDate = datetime(2019-04-28);
range day from endDate - 120d to endDate step 1d
| summarize days = makelist(replace("-", "", substring(day, 0, 10)))
| project array_strcat(days, ", ")

syedhassaanahmed

let tablePrefix = "TimeseriesTable";
let partitions = 2;
//
let partitionTables = materialize(
range i from 0 to partitions - 1 step 1
| extend t = strcat(tablePrefix, "_", i)
);
//
let dropTables = toscalar(
partitionTables

syedhassaanahmed

#!/bin/bash

# Download and extract Gremlin Console
curl -o gremlin-console.zip http://apache.mirrors.spacedump.net/tinkerpop/3.3.1/apache-tinkerpop-gremlin-console-3.3.1-bin.zip
unzip -n gremlin-console.zip && rm gremlin-console.zip

# Download GraphML data of air routes into /mydata
curl --create-dirs -o /mydata/air-routes.graphml https://raw.githubusercontent.com/krlawrence/graph/master/sample-data/air-routes.graphml

# Download groovy script to load data

syedhassaanahmed

#!/bin/bash

# Script is idempotent
CLUSTERNAME=$1
PASSWORD=$2
TOPIC=$3

# Import HDInsight helper method module
wget -O /tmp/HDInsightUtilities-v01.sh -q https://hdiconfigactions.blob.core.windows.net/linuxconfigactionmodulev01/HDInsightUtilities-v01.sh && source /tmp/HDInsightUtilities-v01.sh && rm -f /tmp/HDInsightUtilities-v01.sh

syedhassaanahmed

# Get Custom Shell
Get-WmiObject -namespace root\standardcimv2\embedded -computer localhost -class WESL_UserSetting | Select *

# Remove Custom Shell for SID
([wmiclass]"\\localhost\root\standardcimv2\embedded:WESL_UserSetting").RemoveCustomShell("<User SID>")

# Is Custom Shell Enabled
([wmiclass]"\\localhost\root\standardcimv2\embedded:WESL_UserSetting").IsEnabled()

# Disable Custom Shell

syedhassaanahmed

@powershell -NoProfile -ExecutionPolicy Bypass -Command "iex ((New-Object System.Net.WebClient).DownloadString('https://chocolatey.org/install.ps1'))" && SET "PATH=%PATH%;%ALLUSERSPROFILE%\chocolatey\bin"

choco install 7zip /y
choco install adobereader /y
choco install anaconda3 /y
choco install azure-cli /y
choco install docker-for-windows /y
choco install firefox /y
choco install garmin-express /y
choco install git /y