Azure serverless -- weather alert lab

##Create a resource group 
echo "Create resource group"
az group create --name $resource_group_name  --location $location
## install Azure clit iot extenstion 'Should be done from azure cloud shell'
##az extension add --name azure-cli-iot-ext

##Create IOT hub and add device to the IOT HUB
echo "Create IOT Hub"
az iot hub create --name $iot_hub_name \
                     --resource-group $resource_group_name  \
                     --location $location --sku $sku
##Create iot device 
echo "Create a device to connect to the IOT hub"
az iot hub device-identity create --device-id $iot_device_name \
                   --hub-name $iot_hub_name \
                    --edge-enabled false \
                    --resource-group $resource_group_name

##Get device connection string 
echo "Add IoT Hub Manage policy"
az iot hub policy create --hub-name $iot_hub_name \
                         --name $iot_hub_manage_policy \
                         --permissions RegistryWrite ServiceConnect DeviceConnect \
                         --resource-group $resource_group_name -o json

echo "Connection string to be used to connect your device to the IoT hub :"

az iot hub device-identity show-connection-string \
                         --device-id $iot_device_name  \
                         --hub-name $iot_hub_name  \
                         --resource-group $resource_group_name -o  json \
                         --query connectionString

echo "Creating storage account"
az storage account create \
                --name $weather_storage_account_name \
                 --resource-group $resource_group_name \
                 --access-tier Hot --sku Standard_LRS \
                 --location $location

echo "Creating Table in the created storage account"
az storage table create --name $weather_data \
                        --account-name $weather_storage_account_name 
echo "Table Created"
echo "End of Creating storage account"

az eventhubs namespace create --name $event_Hubs_namespace \
                              --resource-group $resource_group_name \
                              --location $location \
                              --enable-auto-inflate true \
                              --maximum-throughput-units 20 \
                              --sku Standard

## Create an event hub. Specify a name for the event hub. 
az eventhubs eventhub create --name $event_hub_name \
                 --resource-group $resource_group_name \
                  --namespace-name $event_Hubs_namespace

#create write and right access policies
az eventhubs namespace authorization-rule create  \
                    --resource-group  $resource_group_name \
                    --namespace-name $event_Hubs_namespace \
                    --name $sendauthorule \
                    --rights Send

az eventhubs namespace authorization-rule create \
                            --resource-group  $resource_group_name \
                            --namespace-name $event_Hubs_namespace \
                            --name $readauthorule \
                            --rights Listen

SELECT * INTO TableStorage FROM IoTHub
SELECT * INTO EventHub FROM IoTHub WHERE temperature > 29

iot_hub_manage_policy_sas=$(az iot hub policy list --hub-name $iot_hub_name \
             --resource-group $resource_group_name \
             --query "[?contains(keyName, 'manage')].primaryKey" -o tsv)
storage_account_key=$(az storage account keys list \
              --account-name $weather_storage_account_name \  
              --query "[?contains(keyName, 'key1')].value" -o tsv)


eh_policy_send_primary_key=$(az eventhubs namespace authorization-rule  keys list \
            --resource-group  $resource_group_name \
            --namespace-name $event_Hubs_namespace \
            --name $sendauthorule -o tsv --query primaryKey)


echo "Start executing ARM deployment to create ASA"
az deployment group create --resource-group $resource_group_name \
   --name $deploymentName  \
   --template-file $template_file \
   --parameters StreamAnalyticsJobName=$streamAnalyticsJobName \
   Location=$location \
   Input_WeatherAlertIoTHubInput_iotHubNamespace=$iot_hub_name \
   Output_WeatherAlertEventhubOutput_serviceBusNamespace=$event_Hubs_namespace \
   Output_WeatherAlertEventhubOutput_eventHubName=$event_hub_name \
   Output_WeatherAlertEventhubOutput_sharedAccessPolicyName=$sendauthorule \
   Output_WeatherAlertStorageTableOutput_accountName=$weather_storage_account_name \
   Output_WeatherAlertStorageTableOutput_table=$weather_data \
   Output_WeatherAlertStorageTableOutput_partitionKey=$deviceId \
   Output_WeatherAlertStorageTableOutput_rowKey=$enqueuedTimeUtc \
   Input_WeatherAlertIoTHubInput_sharedAccessPolicyName=$iot_hub_manage_policy \
   Input_WeatherAlertIoTHubInput_sharedAccessPolicyKey=$iot_hub_manage_policy_sas \
   Output_WeatherAlertEventhubOutput_sharedAccessPolicyKey=$eh_policy_send_primary_key \
   Output_WeatherAlertStorageTableOutput_accountKey=$storage_account_key

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.EventHubs;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;

namespace weatherAlertFunction
{
    public static class Function1
    {
        [FunctionName("Function1")]
        public static async Task Run([EventHubTrigger("weather-alert-event-eh", Connection = "EventHubConnectionString")] EventData[] events,
                                       [Queue("Alert" , Connection ="weather_alert_storage_account")] IAsyncCollector<string> queue ,
                                    ILogger log)
        {
            var exceptions = new List<Exception>();

            foreach (EventData eventData in events)
            {
                try
                {
                    string messageBody = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);

                    await queue.AddAsync(messageBody);
                    // Replace these two lines with your processing logic.
                    log.LogInformation($"C# Event Hub trigger function processed a message: {messageBody}");
                    await Task.Yield();
                }
                catch (Exception ex)
                { 
                    exceptions.Add(ex);
                }
            }

            // Once processing of the batch is complete, if any messages in the batch failed processing throw an exception so that there is a record of the failure.

            if (exceptions.Count > 1)
                throw new AggregateException(exceptions);

            if (exceptions.Count == 1)
                throw exceptions.Single();
        }
    }
}

storage_account_connection_string=$(az storage account show-connection-string \
            --name  $weather_storage_account_name --resource-group \  
            $resource_group_name --output tsv)

eh_policy_read_primary_connection_string=$(az eventhubs namespace authorization-rule  keys list \
           --resource-group  $resource_group_name  \
           --namespace-name $event_Hubs_namespace 
           --name $readauthorule -o tsv --query primaryConnectionString)

az functionapp deployment source update-token --git-token $token

echo "Create the function app"

az functionapp create --resource-group $resource_group_name \
           --name $weatheralertfunction \
           --storage-account $weather_storage_account_name \
           --runtime dotnet   \
           --functions-version 3   \
           --consumption-plan-location $location \
           --deployment-source-url $gitrepo \
           --deployment-source-branch master
echo "Setup function settings"

az functionapp config appsettings set \
           --resource-group $resource_group_name \
           --name $weatheralertfunction \
           --settings  "weather_alert_storage_account=$storage_account_connection_string"

az functionapp config appsettings set \
         --resource-group $resource_group_name \
         --name $weatheralertfunction \
         --settings  "EventHubConnectionString=$eh_policy_read_primary_connection_string"

echo "Strat Fcuntion"
az functionapp start --resource-group $resource_group_name --name $weatheralertfunction

azurequeues_sharedkey=$(az storage account keys list \
                         --account-name  $weather_storage_account_name \
                         --query "[?contains(keyName, 'key1')].value" -o tsv)


echo "Start executing ARM deployment to create LogicAPP"
az deployment group create --resource-group $resource_group_name \
                            --name $deploymentName  \
                            --template-file $logicapp_template_file \
                            --parameters logicAppName=$logicAppName \
                              azurequeues_storageaccount=$weather_storage_account_name \
                              azurequeues_sharedkey=$azurequeues_sharedkey \
                              email_to=$email_to \
                              sendgrid_apiKey=$send_grid_api_key