AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 79583941
Accepted
user26777519
user26777519
Asked: 2025-04-21 10:05:31 +0800 CST2025-04-21 10:05:31 +0800 CST 2025-04-21 10:05:31 +0800 CST

Melhore um grande número de chamadas paralelas ao serviço blob devido ao Promise.all

  • 772

Tentei implementar o upload de imagens usando o recurso BlobStorage do Azure. Tenho um método no meu frontend Next.js que chama o backend para criar URLs de blob exclusivas para as imagens adicionadas pelo usuário após a edição do formulário. O problema é que usei Promise.all, que bombardeou meu backend com solicitações paralelas, resultando na execução destas duas linhas mais de 20 vezes:

var blobContainerClient = _blobServiceClient.GetBlobContainerClient(_imagesContainerName);
var blobClient = blobContainerClient.GetBlobClient(uniqueFileName); 

Cheguei à conclusão de que este é o problema principal. Depois de chamar este método, não só meu VS travou, como mesmo após reiniciá-lo, não consigo acessar algumas páginas do meu aplicativo devido a inúmeras solicitações pendentes.

Estou realmente confuso com o problema e como corrigi-lo. Tentei verificar o BlobStorage no Azure em busca de conexões abertas, pensando que, mesmo depois de reiniciar o aplicativo, elas ainda persistiam de alguma forma. Não encontrei nada aqui. Verifiquei as métricas do backend implantado e encontrei apenas um pico enorme no uso da CPU e mais de 200 solicitações (a maioria provavelmente sendo uploads de imagens). Tenho quase certeza de que esgotei meu pool de conexões, mas não entendo por que meu programa consome tantos recursos mesmo após a reinicialização, e metade das chamadas ao banco de dados demoram uma eternidade para serem concluídas.

const processedChapters = await Promise.all(
        chapters.map(async (chapter) => {
          const search_language = getSearchLanguage(diplomaSettings.languages);

          if (chapter.images && chapter.images.length > 0) {
            const uploadedImages = await Promise.all(
              chapter.images.map(async (imageDataUrl, index) => {

                if (
                  typeof imageDataUrl === "string" &&
                  imageDataUrl.startsWith("data:")
                ) {
                  const imageUrl = await uploadImageToBlobStorage(
                    imageDataUrl,
                    chapter.id,
                    index
                  );
                  return imageUrl;
                }

                return imageDataUrl;
              })
            );

            return {
              ...chapter,
              search_language,
              images: uploadedImages.filter((url) => url !== null),
            };
          }


          return {
            ...chapter,
            search_language,
          };
        })
      );

Aqui está o código de backend que é chamado do frontend:

    public string GetUploadUrl(string fileName)
    {
        var uniqueFileName = $"{Path.GetFileNameWithoutExtension(fileName)}-{Guid.NewGuid()}{Path.GetExtension(fileName)}";

        var blobContainerClient = _blobServiceClient.GetBlobContainerClient(_imagesContainerName);
        var blobClient = blobContainerClient.GetBlobClient(uniqueFileName);

        var sasBuilder = new BlobSasBuilder
        {
            BlobContainerName = _imagesContainerName,
            BlobName = uniqueFileName,
            Resource = "b",
            ExpiresOn = DateTime.UtcNow.AddMinutes(15)
        };

        sasBuilder.SetPermissions(BlobSasPermissions.Write | BlobSasPermissions.Create | BlobSasPermissions.Read);

        var storageSharedKeyCredential = new StorageSharedKeyCredential(_accountName, _accountKey);
        var sasQueryParameters = sasBuilder.ToSasQueryParameters(storageSharedKeyCredential);
        var sasUrl = $"{blobClient.Uri}?{sasQueryParameters}";

        return sasUrl;
    }
  • 1 1 respostas
  • 58 Views

1 respostas

  • Voted
  1. Best Answer
    Venkatesan
    2025-04-22T15:49:41+08:002025-04-22T15:49:41+08:00

    Como posso evitar sobrecarga de backend e solicitações pendentes ao carregar várias imagens no Armazenamento de Blobs do Azure usando Promise.allNext.js?

    O problema acima ocorre porque o uso Promise.allde uploads de imagens faz com que seu frontend bombardeie o backend com solicitações paralelas. Cada upload de imagem envolve a geração de uma URL SAS por meio da criação de um BlobClient, o que pode sobrecarregar o backend e esgotar recursos (como pools de threads ou limites de soquetes de saída), resultando em instâncias VS congeladas e solicitações pendentes indefinidamente.

    Você pode corrigir isso limitando a simultaneidade no frontend usando a p-mapbiblioteca, o que permite o mapeamento de promessas com um número controlado de execuções simultâneas.

    Atualize o código no seu frontend:

    import pMap from 'p-map';
    
    const uploadedImages = await pMap(
      chapter.images,
      async (imageDataUrl, index) => {
        if (typeof imageDataUrl === 'string' && imageDataUrl.startsWith('data:')) {
          return await uploadImageToBlobStorage(imageDataUrl, chapter.id, index);
        }
        return imageDataUrl;
      },
      { concurrency: 5 } // Limits to 5 parallel uploads
    );
    

    O código acima evita a sobrecarga do backend permitindo apenas 5 uploads por vez, melhorando drasticamente a estabilidade e a capacidade de resposta do backend.

    • 0

relate perguntas

  • Adicionar número de série para atividade de cópia ao blob

  • A fonte dinâmica do empacotador duplica artefatos

  • Selecione linhas por grupo com 1s consecutivos

  • Lista de chamada de API de gráfico subscritoSkus estados Privilégios insuficientes enquanto os privilégios são concedidos

  • Função para criar DFs separados com base no valor da coluna

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve