使用 ADOMDClient 在 Azure 函数中解析对 JSON 的 Azure 分析响应

Question

我正在使用 Microsoft.AnalysisServices.AdomdClient.dll 文件连接到 Azure 分析服务以在 Azure 函数中执行 DAX 查询，我需要它在 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)

Answer 1

我在 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");
    }

}

使用 ADOMDClient 在 Azure 函数中解析对 JSON 的 Azure 分析响应

Parsing Azure Analysis Response to a JSON in Azure function using ADOMDClient

c#

json.net

azure-functions

azure-analysis-services

adomd.net