第12章クラウドネイティブアプリケーション開発

RESOURCE_GROUP=<value>
EVENT_HUB_NAMESPACE=<value>
EVENT_HUB_NAME=<value>
EVENT_HUB_AUTHORIZATION_RULE=<value>
COSMOS_DB_ACCOUNT=<value>
STORAGE_ACCOUNT=<value>
FUNCTION_APP=<value>
LOCATION=<value>

az cosmosdb create\
  --resource-group $RESOURCE_GROUP\
  --name $COSMOS_DB_ACCOUNT

az cosmosdb sql database create\
  --resource-group $RESOURCE_GROUP\
  --account-name $COSMOS_DB_ACCOUNT \
  --name TelemetryDb

az cosmosdb sql container create\
  --resource-group $RESOURCE_GROUP\
  --account-name $COSMOS_DB_ACCOUNT\
  --database-name TelemetryDb\
  --name TelemetryInfo\
  --partition-key-path '/temperatureStatus'

az eventhubs namespace create\
  --resource-group $RESOURCE_GROUP\
  --name $EVENT_HUB_NAMESPACE

az eventhubs eventhub create\
  --resource-group $RESOURCE_GROUP\
  --name $EVENT_HUB_NAME\
  --namespace-name $EVENT_HUB_NAMESPACE\
  --message-retention 1

az eventhubs eventhub authorization-rule create\
  --resource-group $RESOURCE_GROUP
  --name $EVENT_HUB_AUTHORIZATION_RULE
  --eventhub-name $EVENT_HUB_NAME
  --namespace-name $EVENT_HUB_NAMESPACE \
  --rights Listen Send

az storage account create\
  --resource-group $RESOURCE_GROUP\
  --name $STORAGE_ACCOUNT"p" \
  --sku Standard_LRS

az functionapp create\
  --resource-group $RESOURCE_GROUP\
  --name $FUNCTION_APP"-p"\
  --storage-account $STORAGE_ACCOUNT"p" \
  --consumption-plan-location $LOCATION\
  --runtime java\
  --functions-version 4

AZURE_WEB_JOBS_STORAGE=$(\
az storage account show-connection-string\
  --resource-group $RESOURCE_GROUP\
  --name $STORAGE_ACCOUNT"p"\
  --query connectionString\
  --output tsv)

EVENT HUB_CONNECTION_STRING=$(\
az eventhubs eventhub authorization-rule keys list\
  --resource-group $RESOURCE_GROUP\
  --name $EVENT_HUB_AUTHORIZATION_RULE\
  --eventhub-name $EVENT_HUB_NAME\
  --namespace-name $EVENT_HUB_NAMESPACE\
  --query primaryConnectionString\
  --output tsv)

echo $AZURE_WEB_JOBS_STORAGE
echo $EVENT_HUB_CONNECTION_STRING

az functionapp config appsettings set\
  --resource-group $RESOURCE_GROUP\
  --name $FUNCTION_APP"-p" \
  --settings\
AzureWebJobsStorage=$AZURE_WEB_JOBS_STORAGE\
EventHubConnectionString=$EVENT_HUB_CONNECTION_STRING

mvn archetype:generate -batch-mode\
  -DarchetypeGroupid=com.microsoft.azure\
  -Darchetype ArtifactId=azure-functions-archetype\
  -DappName=$FUNCTION_APP"-p"\
  -DresourceGroup=$RESOURCE_GROUP\
  -DappRegion=$LOCATION\
  -DappServicePlanName=$LOCATION"plan" \
  -Dgroupid=com.learn\
  -DartifactId=telemetry-functions-producer

func azure functionapp fetch-app-settings $FUNCTION_APP”-p”

package com.learn;
import com.microsoft.azure.functions.annotation.EventHubOutput;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.TimerTrigger;
import com.microsoft.azure.functions.ExecutionContext;

public class Function {

  @FunctionName("generatesSensorData")
  @EventHubOutput(
  name = "event",
  eventHubName = "", // blank because the value is included in the connection string
  connection = "EventHub ConnectionString")
  public Telemetryltem generateSensorData(
  @TimerTrigger(
  name = "timerInfo",
  schedule = "*/10*****") // every 10 seconds
  String timerInfo,
  final ExecutionContext context) {
    context.getLogger().info("Java Timer trigger function executed at:"+java.time.LocalDateTime.now()); double temperature = Math.random()* 100;
    double pressure = Math.random() * 50;
    return new Telemetryltem(temperature, pressure);
  }
}

package com.learn;
public class TelemetryItem {

  private String id;
  private double temperature;
  private double pressure;
  private boolean isNormalPressure;
  private status temperatureStatus;

  static enum status {
    COOL,
    WARM,
    HOT
  }

  public TelemetryItem(double temperature, double pressure) {
    this.temperature = temperature;
    this.pressure = pressure;
  }

  public String getId() {
    return id;
  }

  public double getTemperature() {
    return temperature;
  }

  public double getPressure() {
    return pressure;
  }

  @Override
  public String toString() {
    return "TelemetryItem={ id=" + id + ",temperature=" + temperature +
",pressure= " + pressure + "}";
  }

  public boolean isNormalPressure() {
    return isNormalPressure;
  }

  public void setNormalPressure(boolean isNormal) {
    this.isNormalPressure = isNormal;
  }
  public status getTemperatureStatus() {
    return temperatureStatus;
  }

  public void setTemperatureStatus(status temperatureStatus)
{
    this.temperatureStatus = temperatureStatus;
  }
}

mvn clean package

Mvn azure-functions:run

mvn azure-functions:deploy