UPDATE
You can find your sastoken
at portal like my pic.
And u also need to update the value of x-ms-date
(Required. Specifies the Coordinated Universal Time (UTC) for the request.) in HttpHelper
file .
For more details, you can download my demo code in github( You can download my HttpHelper
file).
using Microsoft.Azure.Cosmos.Table;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
using static ODatafilter.HttpHelper;
namespace ODatafilter
{
class Program
{
static async Task Main(string[] args)
{
Console.WriteLine("Azure Cosmos Table Samples");
string baseurl = @"https://panshubeistorage.table.core.windows.net/";
string tbname = "People";//Console.ReadLine();
string sastoken = @"?sv=2019-10-10&ss=************";
string filter = @"&$filter=PartitionKey%20eq%20'Smith'%20";
baseurl = baseurl + tbname + "()" + sastoken+filter;
HttpResponseData data = HttpHelper.GetForOData(baseurl);
string responseData = data.Data.Replace(".","_");
ODataResponse odata = JsonConvert.DeserializeObject<ODataResponse>(responseData);
foreach (ODatavalue m in odata.value)
{
Console.WriteLine(m.PartitionKey + " " + m.PhoneNumber + " " + m.RowKey + " " + m.Email);
}
Console.WriteLine("Press any key to exit");
Console.Read();
}
public class ODataResponse
{
public string odata_metadata { get; set; }
public List<ODatavalue> value { get; set; }
}
public class ODatavalue {
public string odata_type { get; set; }
public string odata_id { get; set; }
public string odata_etag { get; set; }
public string odata_editLink { get; set; }
public string Timestamp { get; set; }
public string PartitionKey { get; set; }
public string RowKey { get; set; }
public string Email { get; set; }
public string PhoneNumber { get; set; }
}
}
}
PRIVIOUS
You can use LinQ to query like the document like you supported.
static async Task Main(string[] args)
{
Console.WriteLine("Azure Cosmos Table Samples");
Console.WriteLine("Query data by filter");
CloudTable table = GetTable();
Console.WriteLine("pls input PartitionKey:");
string PartitionKey = Console.ReadLine();
Console.WriteLine("pls input RowKey:");
string RowKey = Console.ReadLine();
//Query
IQueryable<CustomerEntity> linqQuery = table.CreateQuery<CustomerEntity>()
.Where(x => x.PartitionKey== PartitionKey && x.RowKey== RowKey)
.Select(x => new CustomerEntity() { PartitionKey = x.PartitionKey, RowKey = x.RowKey, Email = x.Email, PhoneNumber= x.PhoneNumber });
var list = linqQuery.ToList<CustomerEntity>();
foreach (CustomerEntity m in list)
{
Console.WriteLine(m.PartitionKey+" "+m.PhoneNumber+" "+m.RowKey+" "+m.Email);
}
Console.WriteLine();
Console.WriteLine("Press any key to exit");
Console.Read();
}
public static CloudTable GetTable() {
CloudStorageAccount account = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=***x=core.windows.net");
CloudTableClient tableClient = account.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("People");
return table;
}
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…