O OSS AI VibeFlow é um service de produção e transformação de dados multimodais fornecido pelo Object Storage Service (OSS). Com o AI VibeFlow, você cria um DataPipeline para transformar automaticamente dados não estruturados — como textos, imagens e vídeos — armazenados em um bucket de objetos do OSS em dados vetoriais e gravar os vetores em um índice vetorial dentro de um bucket vetorial do OSS. As capacidades de automação do AI VibeFlow permitem concluir todo o fluxo de trabalho de "upload de dados brutos → vetorização de dados → armazenamento de dados vetoriais → recuperação semântica" diretamente no OSS, o que aumenta significativamente a eficiência na produção e transformação de dados multimodais.
Este recurso está disponível atualmente apenas para usuários incluídos na lista de permissões. Para utilizá-lo, entre em contato com o suporte técnico e envie uma solicitação.
Conceitos principais
DataPipeline: objeto central de gerenciamento no AI VibeFlow. Cada DataPipeline corresponde a uma única regra de vetorização e é executado automaticamente após a criação.
Dados de source: definem a fonte dos dados brutos a serem vetorizados, incluindo o bucket de source, o prefixo do objeto, os tipos de arquivo (texto, imagem e vídeo) e o modo de processamento (dados existentes, dados incrementais ou ambos).
Configurações de vetorização: especificam a source do modelo vetorial, a chave de API do Model Studio, o modelo vetorial, a frequência de captura de quadros de vídeo (disponível apenas para modelos multimodais) e se a exclusão dos vetores correspondentes deve ocorrer em cascata quando o objeto de source for excluído.
Dados de destino: determinam o bucket vetorial de destino, o índice vetorial e a regra de nomenclatura da chave vetorial onde os dados vetoriais serão gravados, além de indicar se ObjectTag e UserMeta devem ser escritos como metadados escalares.
Tratamento de exceções: estabelece a política de processamento quando uma tarefa individual de vetorização falha (ignorar e continuar, ignorar e registrar log ou encerrar imediatamente) e permite especificar o bucket e o prefixo que receberão as mensagens de erro.
Benefícios
Fluxo de trabalho ponta a ponta: grandes volumes de dados brutos não estruturados, o processo de vetorização e o armazenamento de dados vetoriais são tratados integralmente dentro do OSS em um ciclo fechado, simplificando o pipeline de produção.
Processamento automático: oferece suporte tanto à vetorização em lote de dados existentes quanto à vetorização automática de novos dados enviados, sem necessidade de intervenção manual.
Atualização sincronizada de dados: quando os dados brutos no bucket de objetos forem modificados, sobrescritos ou excluídos, escolha atualizar e excluir sincronizadamente os dados vetoriais correspondentes no bucket vetorial, reduzindo os custos de manutenção manual.
Modelos vetoriais flexíveis: chama diretamente os modelos vetoriais de texto e multimodais fornecidos pelo Alibaba Cloud Model Studio (como text-embedding-v4 e tongyi-embedding-vision-plus), permitindo selecionar o modelo e as dimensões adequados conforme as necessidades do seu negócio.
Custos transparentes: a vetorização utiliza sua própria chave de API do Model Studio, e as taxas de embedding são cobradas diretamente pelo Model Studio. No lado do OSS, você paga apenas pelas solicitações de API e pelo armazenamento vetorial, sem tarifas adicionais de service.
Rastreabilidade de falhas: para cada solicitação com falha, informações como ErrorCode, ErrorMessage e RequestId do Model Studio podem ser salvas como um objeto em um bucket específico, facilitando a localização de problemas e novas tentativas.
Cenários
O AI VibeFlow é adequado para todos os cenários em que é necessário vetorizar grandes volumes de dados não estruturados no OSS. Os casos de uso típicos incluem:
Recuperação semântica e RAG: vetorize documentos, imagens e vídeos em um bucket de objetos do OSS e grave os vetores em um bucket vetorial. Em seguida, combine-os com modelos de linguagem grandes para criar aplicações de Geração Aumentada por Recuperação (RAG).
Busca por imagem e texto no e-commerce: realize a vetorização multimodal de imagens e descrições de products e grave os vetores em um bucket vetorial para oferecer suporte a buscas de imagem por imagem e texto por imagem.
Gestão de ativos de publicidade e marketing: vetorize automaticamente imagens e vídeos de marketing para habilitar a recuperação semântica de ativos e a recomendação de conteúdo similar.
Construção de base de conhecimento empresarial: vetorize documentos de conhecimento interno e imagens de bancos de perguntas e grave os vetores em um bucket vetorial para permitir uma recuperação semântica unificada entre diferentes linhas de negócio.
Governança de conteúdo multimídia: combine a similaridade vetorial com filtragem de metadados escalares para viabilizar o gerenciamento e a distribuição refinados de ativos de imagem e vídeo.
Faturamento
O uso do AI VibeFlow gera as seguintes taxas, cobradas separadamente pelo OSS e pelo Alibaba Cloud Model Studio:
|
Item faturável |
Cobrado por |
Descrição |
|
Taxas de solicitação de API do OSS |
OSS |
Taxas de solicitações de leitura e gravação geradas ao chamar APIs relacionadas ao AI VibeFlow e APIs acionadas automaticamente, como GetObject e PutVectors. |
|
Taxas de armazenamento vetorial |
OSS |
Cobradas com base na quantidade de armazenamento do índice vetorial após a gravação dos dados vetoriais no bucket vetorial. |
|
Taxas de chamada do modelo de embedding |
Alibaba Cloud Model Studio |
Taxas geradas ao chamar seu próprio modelo vetorial do Model Studio durante a vetorização. Essas taxas são cobradas diretamente pelo Model Studio com base no número de chamadas. Fique atento à sua fatura do Model Studio. |
O AI VibeFlow não cobra taxas adicionais de gerenciamento de tarefas. Como a vetorização chama diretamente a chave de API do Model Studio, a velocidade real de processamento é afetada pelo limitador de taxa da API do Model Studio (RPM/TPM). Para aumentar o throughput, solicite uma cota maior de RPM/TPM por meio do console do Model Studio ou entre em contato com o suporte técnico para aumentar o QPS de processamento.
Limites
Uma única conta pode criar até 1.000 DataPipelines em uma única região.
Cada DataPipeline corresponde a um modelo vetorial e a um índice vetorial.
O bucket de objetos de source, o bucket vetorial de destino e o bucket que recebe mensagens de erro devem estar localizados na mesma região.
A capacidade máxima de um único índice vetorial é de 2 bilhões de linhas. Quando o índice atinge o limite, o pipeline entra automaticamente no estado Paused.
Ao extrair ObjectTag e UserMeta como metadados vetoriais, especifique até 10 chaves para cada um.
Permissões
Ao criar um DataPipeline, especifique uma função do RAM que o OSS utilizará para executar tarefas de vetorização em segundo plano. O AI VibeFlow usa uma política de confiança dedicada (datapipeline-oss.aliyuncs.com) e não pode reutilizar outras funções de service, como AliyunOSSRole.
Cenário 1: Conta Alibaba Cloud + nova função (recomendado)
Ao criar um DataPipeline no console, selecione Create Role. O sistema cria automaticamente uma função oss-embedding-{uuid} e conclui todas as configurações de permissão e política de confiança, sem necessidade de operações manuais.
Cenário 2: Operações realizadas por um usuário RAM
Quando um usuário RAM cria um DataPipeline, a conta Alibaba Cloud deve concluir antecipadamente as duas etapas de autorização a seguir. Depois disso, o usuário RAM poderá criar DataPipelines normalmente.
Etapa 1: Conceder permissões de criação de função
Ao criar um DataPipeline, especifique uma função do RAM que o OSS assumirá (AssumeRole) durante a execução de tarefas de vetorização em segundo plano.
Métodos de autorização (escolha um):
Método 1: A conta Alibaba Cloud concede autorização antecipadamente no console do RAM
Faça login no console do RAM com a conta Alibaba Cloud e adicione uma política personalizada para o usuário RAM, concedendo a permissão sts:AssumeRole sobre a função de destino. Exemplo de política:
{
"Statement": [
{
"Action": "sts:AssumeRole",
"Effect": "Allow",
"Resource": "acs:ram::<account-id>:role/<RoleName>"
}
],
"Version": "1"
}
Método 2: Criação rápida no console do AI VibeFlow
Na etapa "Authorized Role" do assistente de criação do DataPipeline, selecione "Create Role". O sistema cria automaticamente a função oss-embedding-{uuid} e a vincula ao usuário RAM atual, sem exigir operações adicionais da conta Alibaba Cloud.
Observação: Para usar a criação rápida, o usuário RAM deve ter as seguintes permissões do RAM, que a conta Alibaba Cloud precisa conceder antecipadamente no console do RAM:
{
"Version": "1",
"Statement": [
{
"Effect": "Allow",
"Action": [
"ram:CreateRole",
"ram:CreatePolicy",
"ram:AttachPolicyToRole"
],
"Resource": "*"
}
]
}
Etapa 2: Confirmar as permissões da função e a política de confiança
Ao usar "Create Role" para criação rápida, o sistema configura automaticamente a política de permissões e a política de confiança da função, sem necessidade de operações manuais. Se você optar por uma função personalizada, garanta que ela tenha as seguintes configurações:
Política de permissões (permissões operacionais exigidas pela função):
{
"Version": "1",
"Statement": [
{
"Action": [
"oss:GetObject",
"oss:GetObjectTagging",
"oss:GetBucketStat",
"oss:ListObjects"
],
"Resource": [
"acs:oss:*:*:<source-bucket-name>",
"acs:oss:*:*:<source-bucket-name>/*"
],
"Effect": "Allow"
},
{
"Action": [
"oss:GetVectorIndex",
"oss:PutVectors",
"oss:DeleteVectors"
],
"Resource": [
"acs:ossvector:*:*:<vector-bucket-name>",
"acs:ossvector:*:*:<vector-bucket-name>/<vector-index-name>"
],
"Effect": "Allow"
},
{
"Action": [
"oss:PutObject",
"oss:GetBucketStat"
],
"Resource": [
"acs:oss:*:*:<error-output-bucket-name>",
"acs:oss:*:*:<error-output-bucket-name>/*"
],
"Effect": "Allow"
}
]
}
O prefixo do recurso vetorial é acs:ossvector:*:*: (e não acs:oss:*:*:). Se a exclusão em cascata não estiver configurada, remova oss:DeleteVectors. Caso nenhum bucket esteja configurado para receber mensagens de erro, remova o terceiro Statement.
Política de confiança (permite que o service OSS assuma a função):
{
"Statement": [
{
"Action": "sts:AssumeRole",
"Effect": "Allow",
"Principal": {
"Service": [
"datapipeline-oss.aliyuncs.com"
]
}
}
],
"Version": "1"
}