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);
}
}