並行要求を送信する

ServiceClient クラスまたは CrmServiceClient クラスをご利用の場合は、App.config ファイルの AppSettings ノードに以下を追加します。

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

EnableAffinityCookie プロパティを ServiceClient または CrmServiceClient のいずれかでプロパティの値を設定することもできます

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

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

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 応答値は、RecommendedDegreesOfParallelism プロパティを介して、ServiceClient または CrmServiceClient で取得できます。 Parallel.ForEach を使用するときに、ParallelOptions.MaxDegreeOfParallelism を設定するときに、この値を使用する必要があります。

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

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

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

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

/// <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 で使用できる クローン メソッドは、Dataverse への既存の接続の複製を許可するので、Parallel.ForEach メソッドを使用できます。

/// <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();
}