Анализ ответа Azure анализа на функцию JSON в Azure с использованием ADOMDClient - PullRequest
Новая
       31

Анализ ответа Azure анализа на функцию JSON в Azure с использованием ADOMDClient

0 голосов
/ 17 июня 2020

Я использую файл Microsoft.AnalysisServices.AdomdClient.dll для подключения к Azure Analysis Service для выполнения запросов DAX в функции Azure, и мне нужно, чтобы он выплевывал в JSON. Ниже показано, как у меня дела, но когда есть обширные записи, я вижу задержку при преобразовании ответа в json. Ответ службы анализа за 2 секунды, но маскировка ответа на json занимает более 40 секунд. Может ли кто-нибудь помочь предложить лучший способ 

AdomdCommand cmd = new AdomdCommand(query, _connect);
public List<Dictionary<string, object>> Results { get; } = new List<Dictionary<string, object>>();
var reader = cmd.ExecuteReader();
var schemeTable = reader.GetSchemaTable();
ISet<string> columnSet = new HashSet<string>();
foreach (DataRow row in schemeTable.Rows)
{
 String columnName = row[0].ToString();
 columnSet.Add(columnName);
}
while (reader.Read())
{
 Dictionary<string, object> columns = new Dictionary<string, object>();
 foreach (string columnName in columnSet)
 {
 var value = reader[reader.GetOrdinal(columnName)];
 if (value != null)
 {
  columns.Add(columnName, value);
 }
 else
 {
  columns.Add(columnName, null);
 }
}
 Results.Add(columns);
}
JsonConvert.SerializeObject(Results)

1 Ответ

0 голосов
/ 17 июня 2020

У меня есть образец для этого на GitHub: microsoft / azure -analysis-services-http-sample . Он передает результаты из AdomdDataReader в выходной поток как JSON. Stream может быть MemoryStream или (в моем случае) потоком HttpResponse. 

public static async Task WriteResultsToStream(object results, Stream stream, CancellationToken cancel)
{

    if (results == null)
    {
        return;
    }

    if (results is AdomdDataReader rdr)
    {
        var encoding = new System.Text.UTF8Encoding(false);
        using (var tw = new StreamWriter(stream,encoding,1024*4,true))
        using (var w = new Newtonsoft.Json.JsonTextWriter(tw))
        {

            await w.WriteStartObjectAsync(cancel);
            var rn = "rows";

            await w.WritePropertyNameAsync(rn);
            await w.WriteStartArrayAsync(cancel);

            while (rdr.Read())
            {
                await w.WriteStartObjectAsync(cancel);
                for (int i = 0; i < rdr.FieldCount; i++)
                {
                    string name = rdr.GetName(i);
                    object value = rdr.GetValue(i);

                    await w.WritePropertyNameAsync(name, cancel);
                    await w.WriteValueAsync(value, cancel);
                }
                await w.WriteEndObjectAsync(cancel);
            }

            await w.WriteEndArrayAsync(cancel);
            await w.WriteEndObjectAsync(cancel);

            await w.FlushAsync();
            await tw.FlushAsync();
            await stream.FlushAsync();
        }
    }
    else if (results is CellSet  cs)
    {
        throw new NotSupportedException("CellSet results");

    }
    else
    {
        throw new InvalidOperationException("Unexpected result type");
    }

}
...