dequeue.cs

[FunctionName("DequeueGeneratedNames")]
[return: Blob("raw-names/{id}.txt", FileAccess.Write, Connection = "AzureWebJobsStorage")]
public static async Task<string> Run(
    [ServiceBusTrigger("newnames-queue", Connection = "ServiceBusConnection")]NamesGenerationRecord msg,
    [EventHub("names", Connection = "EventHubSendConnection")]IAsyncCollector<string> outputEvents,
    ILogger log)
{
    foreach (var nameRecord in msg.GeneratedNames)
    {
        await outputEvents.AddAsync(nameRecord.ToString());
    }
    
    return msg.ToString();
}