並行要求を送信する

ServiceClient クラスまたは CrmServiceClient クラスを使用している場合は、AppSettings ファイルの App.config ノードに次のコードを追加します。

<add key="PreferConnectionAffinity" value="false" />

EnableAffinityCookie クラスまたは CrmServiceClient クラスを使用して、 プロパティの値を設定することもできます。

このプロパティは、 ServiceClient(ConnectionOptions、Boolean、ConfigurationOptions) コンストラクターと ConfigurationOptions.EnableAffinityCookie プロパティを使用して設定することもできます。

Web API で HttpClient を使用する .NET アプリケーションの場合、次のコードは、カスタム HttpMessageHandler を使用して Cookie を無効にする方法を示しています。

HttpMessageHandler messageHandler = new OAuthMessageHandler(
    config,
    new HttpClientHandler() { UseCookies = false }
    );
HttpClient httpClient = new HttpClient(messageHandler)

依存関係の挿入を使用している場合は、 ConfigurePrimaryHttpMessageHandler メソッドを使用して 、HttpClientHandler.UseCookies プロパティ を false に設定できます。

IHostBuilder builder = Host.CreateDefaultBuilder();

builder.ConfigureServices(services =>
{
   services.AddHttpClient(
      name: "ClientName",
      configureClient: ConfigureHttpClientDelegate
      )
   .ConfigurePrimaryHttpMessageHandler(() =>
      new HttpClientHandler
      {
            UseCookies = false
      }
   );
});

x-ms-dop-hintまたはの ServiceClient プロパティを使用して、CrmServiceClient応答値にアクセスできます。 Parallel.ForEach を使用するときに ParallelOptions.MaxDegreeOfParallelism を設定するときに、この値を使用します。

これらの例では、EnableAffinityCookie プロパティを false に設定することも示しています。

次の例では、応答の ID 値を GUID の ConcurrentBag に追加します。 ConcurrentBag 順序が問題にならない場合に、オブジェクトのスレッドセーフな順序付けされていないコレクションを提供します。 このメソッドによって返される GUID の順序が、 entityList パラメーターで送信された項目の順序と一致するとは思えません。

.NET 6 以降で ServiceClient を使用する

.NET 6 以降を使用すると、CreateAsync などの ServiceClient に含まれる非同期メソッドで Parallel.ForEachAsync メソッドを使用できます。

/// <summary>
/// Creates records in parallel
/// </summary>
/// <param name="serviceClient">The authenticated ServiceClient instance.</param>
/// <param name="entityList">The list of entities to create.</param>
/// <returns>The id values of the created records.</returns>
static async Task<Guid[]> CreateRecordsInParallel(
    ServiceClient serviceClient, 
    List<Entity> entityList)
{
    ConcurrentBag<Guid> ids = new();

    // Disable affinity cookie
    serviceClient.EnableAffinityCookie = false;

    var parallelOptions = new ParallelOptions()
    { MaxDegreeOfParallelism = 
        serviceClient.RecommendedDegreesOfParallelism };

    await Parallel.ForEachAsync(
        source: entityList,
        parallelOptions: parallelOptions,
        async (entity, token) =>
        {
            ids.Add(await serviceClient.CreateAsync(entity, token));
        });

    return ids.ToArray();
}

.NET Framework での CrmServiceClient の使用

.NET Framework を使用する場合、CrmServiceClient で使用できる Clone メソッドは、Parallel.ForEach メソッドを使用できるように、Dataverse への既存の接続を複製します。

/// <summary>
/// Creates records in parallel
/// </summary>
/// <param name="crmServiceClient">The authenticated CrmServiceClient instance.</param>
/// <param name="entityList">The list of entities to create.</param>
/// <returns>The id values of the created records.</returns>
static Guid[] CreateRecordsInParallel(
    CrmServiceClient crmServiceClient, 
    List<Entity> entityList)
{
   ConcurrentBag<Guid> ids = new ConcurrentBag<Guid>();

    // Disable affinity cookie
    crmServiceClient.EnableAffinityCookie = false;

   Parallel.ForEach(entityList,
      new ParallelOptions()
      {
            MaxDegreeOfParallelism = crmServiceClient.RecommendedDegreesOfParallelism
      },
      () =>
      {
            //Clone the CrmServiceClient for each thread
            return crmServiceClient.Clone();
      },
      (entity, loopState, index, threadLocalSvc) =>
      {
            ids.Add(threadLocalSvc.Create(entity));

            return threadLocalSvc;
      },
      (threadLocalSvc) =>
      {
            //Dispose the cloned crmServiceClient instance
            threadLocalSvc?.Dispose();
      }
   );
   return ids.ToArray();
}

次の静的メソッドの例は、BaseAddress プロパティを Dataverse Web API URI に設定して構成された認証済みの HttpClient を使用する方法を示しています。

このメソッドは、最初に WhoAmI 関数を使用して要求を送信しますが、応答の本文のデータは使用しません。 x-ms-dop-hint応答ヘッダー値は、メソッドに必要なものです。 この値を使用して ParallelOptions.MaxDegreeOfParallelism プロパティを設定します。 その後、 Parallel.ForEachAsync を使用して、これらのオプションを使用して要求を送信します。

次に、このメソッドはレコードの ID 値を解析し、それらを Guid の ConcurrentBag に設定します。 ConcurrentBag 順序が問題にならない場合に、オブジェクトのスレッドセーフな順序付けされていないコレクションを提供します。 このメソッドによって返される Guid の順序は、 entityList パラメーターで送信されたアイテムの順序と一致するとは考えられません。

/// <summary>
/// Creates account records in parallel
/// </summary>
/// <param name="client">Authenticated HttpClient instance</param>
/// <param name="entityList">List of JObject representing account records</param>
/// <returns>The id values of the created records.</returns>
static async Task<Guid[]> CreateRecordsInParallel(HttpClient client, List<JObject> entityList)
{
   ConcurrentBag<Guid> ids = new ConcurrentBag<Guid>();

   HttpResponseMessage whoAmIResponse = await client.SendAsync(new HttpRequestMessage
   {
         Method = HttpMethod.Get,
         RequestUri = new Uri(
         uriString: "WhoAmI",
         uriKind: UriKind.Relative)
   });

   int recommendedDegreeOfParallelism = int.Parse(whoAmIResponse.Headers.GetValues("x-ms-dop-hint").FirstOrDefault());

   var parallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = recommendedDegreeOfParallelism };

   // Send the requests in parallel
   await Parallel.ForEachAsync(entityList, parallelOptions, async (jObject, token) =>
   {
        // Send the request to create an account record.
         var createResponse = await client.SendAsync(new HttpRequestMessage()
         {
            Method = HttpMethod.Post,
            RequestUri = new Uri(
            uriString: "accounts",
            uriKind: UriKind.Relative),
            Content = new StringContent(
               content: jObject.ToString(),
               encoding: System.Text.Encoding.UTF8,
               mediaType: "application/json")
         });

         string? uri = createResponse.Headers.GetValues("OData-EntityId").FirstOrDefault();

         // Parse the Id from the URI returned
         int firstParen = uri.LastIndexOf('(') + 1;
         int lastParen = uri.LastIndexOf(')');

         if (Guid.TryParse(uri[firstParen..lastParen], out Guid id))
         {
            ids.Add(id);
         }

   });

   return ids.ToArray();
}