paulbatum

using System.IO;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Azure.WebJobs.Host;
using Newtonsoft.Json;

namespace TieredJitTest

paulbatum

#r "Microsoft.ServiceBus" 

using System;
using System.Text;
using Microsoft.ServiceBus.Messaging;

public static void Run(EventData myEventHubMessage, TraceWriter log)
{
    log.Info($"C# Event Hub trigger function processed a message with partition key: {myEventHubMessage.PartitionKey}");
}

paulbatum

const decimal executionCountCost = 0.20m / 1000000m;
const decimal gbSecCost = 0.000016m;
const decimal executionUnitsToGbSecConversion = 1m / (1024 * 1000);

long executionCountPerHour = 6500012;
long executionUnitsPerHour = 90305037184;
int runDurationDays = 9;

Console.WriteLine("All prices in USD");

paulbatum

syntax = "proto3";
package sensors;

import "google/protobuf/timestamp.proto";
option csharp_namespace = "EventHubsThroughput.Models.Protobuf";

enum SensorType {
    UNKNOWN = 0;
    SEISMIC = 1;
    WEATHER = 2;

paulbatum

HTTP latency in milliseconds @ 50 RPS

Each row is a 5 minute run at constant load of 50 RPS.

Scenario	Min	Median	P95	P99	Max
Dedicated without fix	154	158.1	999.6	2128	3341.9
Dedicated without fix	154.2	158.8	1204.8	2058.8	3845.8
Dedicated without fix	154	158.6	941	2430.4	4618.1
Dedicated without fix	154.2	158.8	882.1	2089.3	3515.9

paulbatum

using System.Net;
using System.Threading.Tasks.Dataflow;

public enum Mode
{
    Sequential,
    Batches,
    Dataflow
}

paulbatum

{
    "parameters": {
        "name": {
            "type": "string"
        }
    },
    "resources": [
        {
            "apiVersion": "2015-08-01",
            "name": "[parameters('name')]",

paulbatum

{
    "parameters": {
        "name": {
            "type": "string",
            "defaultValue": "pbsynctest4"
        },
        "storageName": {
            "type": "string",
            "defaultValue": "pbsynctest4"
        },

paulbatum

{
  "bindings": [
    {
      "name": "myTimer",
      "type": "timerTrigger",
      "direction": "in",
      "schedule": "*/10 * * * * *"
    },
    {
      "type": "table",

paulbatum

using System;
using System.Threading.Tasks;
using System.Diagnostics;

static Dictionary<int,byte[]> Allocations = new Dictionary<int,byte[]>();

public static async Task Run(string id, int message, TraceWriter log)
{
    log.Verbose($"Machine: {Environment.MachineName}");