My Entity Class
public class VerifyVariableEntity : TableEntity
{
public VerifyVariableEntity()
{
}
public VerifyVariableEntity(string consumerId, string score)
{
PartitionKey = consumerId;
RowKey = score;
}
public string ConsumerId { get; set; }
public string Score { get; set; }
}
I am fetching the data from Azure Service Bus queue, then deserialize it and finally trying to store it into Azure Table Storage. Below is my implementation for fetching the data from Service Bus Queue and storing it into Azure Table Storage.
class Program
{
static void Main(string[] args)
{
var connectionString = "myconnectionString";
var queueName = "myqueueName";
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("StorageConnectionString"));
CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("test");
table.CreateIfNotExists();
var client = QueueClient.CreateFromConnectionString(connectionString, queueName);
client.OnMessage(message =>
{
var bodyJson = new StreamReader(message.GetBody<Stream>(), Encoding.UTF8).ReadToEnd();
var myMessage = JsonConvert.DeserializeObject<VerifyVariable>(bodyJson);
Console.WriteLine(bodyJson);
Console.WriteLine(myMessage.ConsumerId);
Console.WriteLine(myMessage.Score);
var VerifyVariableEntityObject = new VerifyVariableEntity()
{
ConsumerId = myMessage.ConsumerId,
Score = myMessage.Score
};
TableOperation insertOperation = TableOperation.Insert(VerifyVariableEntityObject);
// Execute the insert operation.
table.Execute(insertOperation);
});
Console.ReadLine();
}
}