Test.fs

 let queue  = // ..

    
[<FunctionName("MyFunction")>]
let run([<QueueTrigger("start")>]content:string, log:ILogger) = 
    let t = task { = 
        for i in 1 .. 5000 do
            let message = CloudQueueMessage(Newtonsoft.Json.JsonConvert.SerializeObject msg)
            do! queue.AddMessageAsync(message)
    }
    t.Wait()    

let aggregationQueue = getQueue connected AveragePlant

[<FunctionName("FanOut")>]
let run([<QueueTrigger("FanOut")>] content:string, log:ILogger) =
let t = task {
for i in 1 .. 5000 do
let msg : AggregateRequest = {
MeterId = i |> string
VuPeriode = "2014001"}
let message = CloudQueueMessage(Newtonsoft.Json.JsonConvert.SerializeObject msg)
do! aggregationQueue.AddMessageAsync(message)
}
t.Wait()

let aggregationQueue = getQueue connected AveragePlant

[<FunctionName("FanOut")>]
let run([<QueueTrigger("FanOut")>] content:string, log:ILogger) =
let t = task {
let! _ =
[1..5000]
|> Seq.map (fun i ->
let msg : AggregateRequest = {
MeterId = i |> string
VuPeriode = "2014001"}
let message = CloudQueueMessage(Newtonsoft.Json.JsonConvert.SerializeObject msg)
aggregationQueue.AddMessageAsync(message))
|> Task.WhenAll
()
}
t.Wait()