public async Task Run()

in BuildApplications/ClickStream/ClickStreamDataGenerator/DataGeneratorFunction.cs [16:30]

• 15 lines of code
• 1 McCabe index (conditional complexity)

        public async Task Run([TimerTrigger("0 * * * * *")]TimerInfo myTimer, ILogger log)
        {
            int eventsPerMinute = int.Parse(Environment.GetEnvironmentVariable("eventsPerMinute", EnvironmentVariableTarget.Process));
            string ehConn = Environment.GetEnvironmentVariable("eventHubConnectionString", EnvironmentVariableTarget.Process);
            string eh = "click-stream-events";
            await using (var producerClient = new EventHubProducerClient(ehConn, eh))
            {
                var events = Enumerable.Range(0, eventsPerMinute)
                    .Select(i => new ClickStreamEvent())
                    .Select(traffic => JsonConvert.SerializeObject(traffic))
                    .Select(jsonString => Encoding.UTF8.GetBytes(jsonString))
                    .Select(jsonBytes => new EventData(jsonBytes));
                await producerClient.SendAsync(events);
            }
        }