static void outputCDRRecs()

in DataGenerators/TelcoGenerator/Program.cs [308:337]


        static void outputCDRRecs(CDRrecord r)
        {
            //Console.WriteLine("RecordType,SystemIdentity,FileNum,SwitchNum,CallingNum,CallingIMSI,CalledNum,CalledIMSI,Date,Time,TimeType,CallPeriod,CallingCellID,CalledCellID,ServiceType");
            //Console.WriteLine(r);

            try
            {
                List<Task> tasks = new List<Task>();
                var serializedString = JsonConvert.SerializeObject(r);
                EventData data = new EventData(Encoding.UTF8.GetBytes(serializedString))
                {
                    PartitionKey = r.CallingIMSI
                };

                partitionCurrent++;
                if (partitionCurrent >8)
                    partitionCurrent = 0;

                // Send the metric to Event Hub
                tasks.Add(client.SendAsync(data));

                Console.WriteLine(r);

                Task.WaitAll(tasks.ToArray());
            }
            catch (Exception e)
            {
                Console.WriteLine("Error on send: " + e.Message);
            }
        }