Нужна помощь по использованию documentdb-lumenize на .net documentdb client sdk

Question

У меня возникла проблема с использованием агрегата storedproc lumenize https://github.com/lmaccherone/documentdb-lumenize с клиентом .net. Я получаю сообщение об ошибке при попытке передать параметр и запрос в хранимый файл. Ниже мой код

public async static void QuerySP()  { 
      using (client = new DocumentClient(new Uri(endpointUrl), authorizationKey)) 
      { 
       //Get the Database 
       var database = client.CreateDatabaseQuery().Where(db => db.Id == databaseId).ToArray().FirstOrDefault(); 

       //Get the Document Collection 
       var collection = client.CreateDocumentCollectionQuery(database.SelfLink).Where(c => c.Id == collectionId).ToArray().FirstOrDefault(); 

       StoredProcedure storedProc = client.CreateStoredProcedureQuery(collection.StoredProceduresLink).Where(sp => sp.Id == "cube").ToArray().FirstOrDefault();    


       dynamic result = await client.ExecuteStoredProcedureAsync<dynamic>(storedProc.SelfLink, "{cubeConfig: {groupBy: 'publication', field: 'pid', f: 'count'}, filterQuery: 'SELECT pid, publication FROM c'}"); 
       Console.WriteLine("Result from script: {0}\r\n", result.Response); 
      } 
} 

Я получаю следующее сообщение об ошибке, когда выполнение кода

Message: {"Errors":["Encountered exception while executing Javascript. Exception = Error: cubeConfig or savedCube required\r\nStack trace: Error: cubeConfig or savedCube required\n at fn (cube.js:1803:7)\n at __docDbMain (cube.js:1844:5)\n at Unknown script code (cube.js:1:2)"]}

Не уверен, что я сделал неправильно. Я очень благодарен за помощь. Благодарю.

Answer 1

У вас его почти нет. Проблема в том, что вы отправляете cubeConfig в виде строки. Это должен быть объект. Вот код, который делает это:

string cubeConfigString = @"{ 
    cubeConfig: { 
     groupBy: 'publication', 
     field: 'pid', 
     f: 'count' 
    }, 
    filterQuery: 'SELECT * FROM c' 
}"; 

Object cubeConfig = JsonConvert.DeserializeObject<Object>(cubeConfigString); 
Console.WriteLine(cubeConfig); 

dynamic result = await client.ExecuteStoredProcedureAsync<dynamic>("dbs/dev-test-database/colls/dev-test-collection/sprocs/cube", cubeConfig); 

Console.WriteLine(result.Response); 

Answer 2

мой рабочий код

public async static Task QuerySP2() 
    { 
     using (client = new DocumentClient(new Uri(endpointUrl), authorizationKey)) 
     { 
      //Get the Database 
      var database = client.CreateDatabaseQuery().Where(db => db.Id == databaseId).ToArray().FirstOrDefault(); 

      //Get the Document Collection 
      var collection = client.CreateDocumentCollectionQuery(database.SelfLink).Where(c => c.Id == collectionId).ToArray().FirstOrDefault(); 

      StoredProcedure storedProc = client.CreateStoredProcedureQuery(collection.StoredProceduresLink).Where(sp => sp.Id == "cube").ToArray().FirstOrDefault(); 

      string filterQuery = string.Format(@"SELECT * from c"); 

      string cubeConfigString = @"{ 
       cubeConfig: { 
        groupBy: 'publication', 
        field: 'id', 
        f: 'count' 
       }, 
       filterQuery: '" + filterQuery + "'}"; 

      dynamic cubeConfig = JsonConvert.DeserializeObject<dynamic>(cubeConfigString); 
      Console.WriteLine(cubeConfig); 

      string continuationToken = null; 

      dynamic result=null; 
      do 
      { 


       var queryDone = false; 
       while (!queryDone) 
       { 
        try 
        { 
         result = await client.ExecuteStoredProcedureAsync<dynamic>(storedProc.SelfLink, cubeConfig); 
         cubeConfig = result.Response; 
         continuationToken = cubeConfig.continuation; 
         queryDone = true; 
        } 
        catch (DocumentClientException documentClientException) 
        { 
         var statusCode = (int)documentClientException.StatusCode; 
         if (statusCode == 429 || statusCode == 503) 
          System.Threading.Thread.Sleep(documentClientException.RetryAfter); 
         else 
          throw; 
        } 
        catch (AggregateException aggregateException) 
        { 
         if (aggregateException.InnerException.GetType() == typeof(DocumentClientException)) 
         { 

          var docExcep = aggregateException.InnerException as DocumentClientException; 
          var statusCode = (int)docExcep.StatusCode; 
          if (statusCode == 429 || statusCode == 503) 
           System.Threading.Thread.Sleep(docExcep.RetryAfter); 
          else 
           throw; 
         } 
        } 
       } 



      } while (continuationToken != null); 

      Console.WriteLine("Result from script: {0}\r\n", result.Response); 


     } 


    }