QueueClient class
Um QueueClient representa uma URL para as mensagens de uma Fila de Armazenamento do Azure, permitindo que você manipule suas mensagens.
- Extends
Construtores
| Queue |
Cria uma instância de QueueClient. |
| Queue |
Cria uma instância de QueueClient. |
| Queue |
Cria uma instância de QueueClient. |
Propriedades
| account |
|
| name | O nome da fila. |
| url | Valor da cadeia de caracteres de URL. |
Métodos
| clear |
Clear exclui todas as mensagens de uma fila. |
| create(Queue |
Cria uma nova fila na conta especificada. |
| create |
Cria uma nova fila na conta especificada se ela ainda não existir. Se a fila já existir, ela não será alterada. |
| delete(Queue |
Exclui a fila especificada permanentemente. |
| delete |
Exclui a fila especificada permanentemente se ela existir. |
| delete |
deleteMessage remove permanentemente a mensagem especificada de sua fila. |
| exists(Queue |
Retorna true se a fila especificada existir; falso caso contrário. NOTA: utilize esta função com cuidado, uma vez que uma fila existente pode ser eliminada por outros clientes ou aplicações. Vice-versa, novas filas podem ser adicionadas por outros clientes ou aplicativos após a conclusão dessa função. |
| generate |
Disponível apenas para QueueClient construído com uma credencial de chave compartilhada. Gera um URI SAS (Service Shared Access Signature) com base nas propriedades do cliente e nos parâmetros passados. O SAS é assinado pela credencial de chave compartilhada do cliente. |
| get |
Obtém detalhes sobre quaisquer políticas de acesso armazenado especificadas na fila que podem ser usadas com Assinaturas de Acesso Compartilhado. AVISO: JavaScript Date perderá a precisão ao analisar a cadeia de caracteres de início e expiração. Por exemplo, a nova Data("2018-12-31T03:44:23.8827891Z").toISOString() obterá "2018-12-31T03:44:23.882Z". |
| get |
Obtém todos os metadados definidos pelo usuário e as propriedades do sistema para a fila especificada. Os metadados são associados à fila como pares nome-valores. |
| peek |
peekMessages recupera uma ou mais mensagens da frente da fila, mas não altera a visibilidade da mensagem. |
| receive |
receiveMessages recupera uma ou mais mensagens da frente da fila. |
| send |
sendMessage adiciona uma nova mensagem ao fim de uma fila. O tempo limite de visibilidade especifica por quanto tempo a mensagem deve ficar invisível para as operações Dequeue e Peek. O conteúdo da mensagem tem até 64 KB de tamanho e deve estar em um formato que possa ser incluído em uma solicitação XML com codificação UTF-8. Para incluir marcação na mensagem, o conteúdo da mensagem deve ser com escape de XML ou código Base64. |
| set |
Define políticas de acesso armazenado para a fila que podem ser usadas com Assinaturas de Acesso Compartilhado. |
| set |
Define um ou mais pares nome-valor definidos pelo usuário para a fila especificada. Se nenhuma opção for fornecida, ou nenhum metadados definido no parâmetro option, os metadados da fila serão removidos. |
| update |
A atualização altera o tempo limite de visibilidade e o conteúdo de uma mensagem. O conteúdo da mensagem tem até 64 KB de tamanho e deve estar em um formato que possa ser incluído em uma solicitação XML com codificação UTF-8. Para incluir marcação na mensagem, o conteúdo da mensagem deve ser com escape de XML ou código Base64. |
Detalhes do Construtor
QueueClient(string, Pipeline)
Cria uma instância de QueueClient.
new QueueClient(url: string, pipeline: Pipeline)
Parâmetros
- url
-
string
Uma cadeia de caracteres de URL apontando para a fila de Armazenamento do Azure, como "https://myaccount.queue.core.windows.net/myqueue". Você pode acrescentar uma SAS se estiver usando AnonymousCredential, como "https://myaccount.queue.core.windows.net/myqueue?sasString".
- pipeline
- Pipeline
Chame newPipeline() para criar um pipeline padrão ou forneça um pipeline personalizado.
QueueClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)
Cria uma instância de QueueClient.
new QueueClient(url: string, credential?: StorageSharedKeyCredential | AnonymousCredential | TokenCredential, options?: StoragePipelineOptions)
Parâmetros
- url
-
string
Uma cadeia de caracteres de URL apontando para a fila de Armazenamento do Azure, como "https://myaccount.queue.core.windows.net/myqueue". Você pode acrescentar uma SAS se estiver usando AnonymousCredential, como "https://myaccount.queue.core.windows.net/myqueue?sasString".
- credential
-
StorageSharedKeyCredential | AnonymousCredential | TokenCredential
Como AnonymousCredential, StorageSharedKeyCredential ou qualquer credencial do pacote @azure/identity para autenticar solicitações para o serviço. Você também pode fornecer um objeto que implementa a interface TokenCredential. Se não for especificado, AnonymousCredential será usado.
- options
- StoragePipelineOptions
Opções para configurar o pipeline HTTP.
QueueClient(string, string, StoragePipelineOptions)
Cria uma instância de QueueClient.
new QueueClient(connectionString: string, queueName: string, options?: StoragePipelineOptions)
Parâmetros
- connectionString
-
string
Cadeia de conexão de conta ou uma cadeia de conexão SAS de uma conta de armazenamento do Azure.
[ Observação - A cadeia de conexão da conta só pode ser usada em NODE.JS tempo de execução. ] Exemplo de cadeia de conexão de conta -
DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net exemplo de cadeia de conexão SAS - BlobEndpoint=https://myaccount.blob.core.windows.net/;QueueEndpoint=https://myaccount.queue.core.windows.net/;FileEndpoint=https://myaccount.file.core.windows.net/;TableEndpoint=https://myaccount.table.core.windows.net/;SharedAccessSignature=sasString
- queueName
-
string
Nome da fila.
- options
- StoragePipelineOptions
Opções para configurar o pipeline HTTP.
Detalhes de Propriedade
accountName
accountName: string
Valor de Propriedade
string
name
O nome da fila.
string name
Valor de Propriedade
string
url
Valor da cadeia de caracteres de URL.
url: string
Valor de Propriedade
string
Detalhes de Método
clearMessages(QueueClearMessagesOptions)
Clear exclui todas as mensagens de uma fila.
function clearMessages(options?: QueueClearMessagesOptions)
Parâmetros
- options
- QueueClearMessagesOptions
Opções para limpar a operação de mensagens.
Devoluções
Promise<QueueClearMessagesResponse>
Dados de resposta para a operação de mensagens claras.
create(QueueCreateOptions)
Cria uma nova fila na conta especificada.
function create(options?: QueueCreateOptions)
Parâmetros
- options
- QueueCreateOptions
Opções para a operação de criação de fila.
Devoluções
Promise<QueueCreateResponse>
Dados de resposta para a operação de criação de fila.
Exemplo de uso:
const queueClient = queueServiceClient.getQueueClient("<new queue name>");
const createQueueResponse = await queueClient.create();
createIfNotExists(QueueCreateOptions)
Cria uma nova fila na conta especificada se ela ainda não existir. Se a fila já existir, ela não será alterada.
function createIfNotExists(options?: QueueCreateOptions)
Parâmetros
- options
- QueueCreateOptions
Devoluções
Promise<QueueCreateIfNotExistsResponse>
delete(QueueDeleteOptions)
Exclui a fila especificada permanentemente.
function delete(options?: QueueDeleteOptions)
Parâmetros
- options
- QueueDeleteOptions
Opções para a operação de exclusão de fila.
Devoluções
Promise<QueueDeleteResponse>
Dados de resposta para a operação de exclusão de fila.
Exemplo de uso:
const deleteQueueResponse = await queueClient.delete();
console.log(
"Delete queue successfully, service assigned request Id:", deleteQueueResponse.requestId
);
deleteIfExists(QueueDeleteOptions)
Exclui a fila especificada permanentemente se ela existir.
function deleteIfExists(options?: QueueDeleteOptions)
Parâmetros
- options
- QueueDeleteOptions
Devoluções
Promise<QueueDeleteIfExistsResponse>
deleteMessage(string, string, QueueDeleteMessageOptions)
deleteMessage remove permanentemente a mensagem especificada de sua fila.
function deleteMessage(messageId: string, popReceipt: string, options?: QueueDeleteMessageOptions)
Parâmetros
- messageId
-
string
ID da mensagem.
- popReceipt
-
string
Um valor de recibo pop válido retornado de uma chamada anterior para a operação de receber mensagens ou atualizar mensagens.
- options
- QueueDeleteMessageOptions
Opções para excluir a operação da mensagem.
Devoluções
Promise<QueueDeleteMessageResponse>
Dados de resposta para a operação de exclusão de mensagem.
exists(QueueExistsOptions)
Retorna true se a fila especificada existir; falso caso contrário. NOTA: utilize esta função com cuidado, uma vez que uma fila existente pode ser eliminada por outros clientes ou aplicações. Vice-versa, novas filas podem ser adicionadas por outros clientes ou aplicativos após a conclusão dessa função.
function exists(options?: QueueExistsOptions)
Parâmetros
- options
- QueueExistsOptions
opções para a operação Existe.
Devoluções
Promise<boolean>
generateSasUrl(QueueGenerateSasUrlOptions)
Disponível apenas para QueueClient construído com uma credencial de chave compartilhada. Gera um URI SAS (Service Shared Access Signature) com base nas propriedades do cliente e nos parâmetros passados. O SAS é assinado pela credencial de chave compartilhada do cliente.
function generateSasUrl(options: QueueGenerateSasUrlOptions)
Parâmetros
- options
- QueueGenerateSasUrlOptions
Parâmetros opcionais.
Devoluções
string
O URI SAS que consiste no URI para o recurso representado por este cliente, seguido pelo token SAS gerado.
getAccessPolicy(QueueGetAccessPolicyOptions)
Obtém detalhes sobre quaisquer políticas de acesso armazenado especificadas na fila que podem ser usadas com Assinaturas de Acesso Compartilhado. AVISO: JavaScript Date perderá a precisão ao analisar a cadeia de caracteres de início e expiração. Por exemplo, a nova Data("2018-12-31T03:44:23.8827891Z").toISOString() obterá "2018-12-31T03:44:23.882Z".
function getAccessPolicy(options?: QueueGetAccessPolicyOptions)
Parâmetros
- options
- QueueGetAccessPolicyOptions
Opções para Fila obter operação de política de acesso.
Devoluções
Promise<QueueGetAccessPolicyResponse>
Dados de resposta para a operação da política de acesso de obtenção de fila.
getProperties(QueueGetPropertiesOptions)
Obtém todos os metadados definidos pelo usuário e as propriedades do sistema para a fila especificada. Os metadados são associados à fila como pares nome-valores.
function getProperties(options?: QueueGetPropertiesOptions)
Parâmetros
- options
- QueueGetPropertiesOptions
Opções para Fila obter propriedades operação.
Devoluções
Promise<QueueGetPropertiesResponse>
Dados de resposta para a operação Queue get properties.
peekMessages(QueuePeekMessagesOptions)
peekMessages recupera uma ou mais mensagens da frente da fila, mas não altera a visibilidade da mensagem.
function peekMessages(options?: QueuePeekMessagesOptions)
Parâmetros
- options
- QueuePeekMessagesOptions
Opções para espiar a operação de mensagens.
Devoluções
Promise<QueuePeekMessagesResponse>
Dados de resposta para a operação de mensagens de visualização.
Exemplo de uso:
const peekMessagesResponse = await queueClient.peekMessages();
console.log("The peeked message is:", peekMessagesResponse.peekedMessageItems[0].messageText);
receiveMessages(QueueReceiveMessageOptions)
receiveMessages recupera uma ou mais mensagens da frente da fila.
function receiveMessages(options?: QueueReceiveMessageOptions)
Parâmetros
- options
- QueueReceiveMessageOptions
Opções para receber mensagens de operação.
Devoluções
Promise<QueueReceiveMessageResponse>
Dados de resposta para a operação de recebimento de mensagens.
Exemplo de uso:
const response = await queueClient.receiveMessages();
if (response.receivedMessageItems.length == 1) {
const receivedMessageItem = response.receivedMessageItems[0];
console.log("Processing & deleting message with content:", receivedMessageItem.messageText);
const deleteMessageResponse = await queueClient.deleteMessage(
receivedMessageItem.messageId,
receivedMessageItem.popReceipt
);
console.log(
"Delete message successfully, service assigned request Id:",
deleteMessageResponse.requestId
);
}
sendMessage(string, QueueSendMessageOptions)
sendMessage adiciona uma nova mensagem ao fim de uma fila. O tempo limite de visibilidade especifica por quanto tempo a mensagem deve ficar invisível para as operações Dequeue e Peek. O conteúdo da mensagem tem até 64 KB de tamanho e deve estar em um formato que possa ser incluído em uma solicitação XML com codificação UTF-8. Para incluir marcação na mensagem, o conteúdo da mensagem deve ser com escape de XML ou código Base64.
function sendMessage(messageText: string, options?: QueueSendMessageOptions)
Parâmetros
- messageText
-
string
Texto da mensagem a enviar
- options
- QueueSendMessageOptions
Opções para enviar mensagens operação.
Devoluções
Promise<QueueSendMessageResponse>
Dados de resposta para a operação de envio de mensagens.
Exemplo de uso:
const sendMessageResponse = await queueClient.sendMessage("Hello World!");
console.log(
"Sent message successfully, service assigned message Id:", sendMessageResponse.messageId,
"service assigned request Id:", sendMessageResponse.requestId
);
setAccessPolicy(SignedIdentifier[], QueueSetAccessPolicyOptions)
Define políticas de acesso armazenado para a fila que podem ser usadas com Assinaturas de Acesso Compartilhado.
function setAccessPolicy(queueAcl?: SignedIdentifier[], options?: QueueSetAccessPolicyOptions)
Parâmetros
- queueAcl
- options
- QueueSetAccessPolicyOptions
Opções para Fila definem a operação da política de acesso.
Devoluções
Promise<QueueSetAccessPolicyResponse>
Dados de resposta para a operação da política de acesso do conjunto de filas.
setMetadata(Metadata, QueueSetMetadataOptions)
Define um ou mais pares nome-valor definidos pelo usuário para a fila especificada. Se nenhuma opção for fornecida, ou nenhum metadados definido no parâmetro option, os metadados da fila serão removidos.
function setMetadata(metadata?: Metadata, options?: QueueSetMetadataOptions)
Parâmetros
- metadata
- Metadata
Se não forem fornecidos metadados, todos os metadados existentes serão removidos.
- options
- QueueSetMetadataOptions
Opções para Operação de metadados de conjunto de fila.
Devoluções
Promise<QueueSetMetadataResponse>
Dados de resposta para a operação de metadados do conjunto de filas.
updateMessage(string, string, string, number, QueueUpdateMessageOptions)
A atualização altera o tempo limite de visibilidade e o conteúdo de uma mensagem. O conteúdo da mensagem tem até 64 KB de tamanho e deve estar em um formato que possa ser incluído em uma solicitação XML com codificação UTF-8. Para incluir marcação na mensagem, o conteúdo da mensagem deve ser com escape de XML ou código Base64.
function updateMessage(messageId: string, popReceipt: string, message?: string, visibilityTimeout?: number, options?: QueueUpdateMessageOptions)
Parâmetros
- messageId
-
string
ID da mensagem
- popReceipt
-
string
Um valor de recibo pop válido retornado de uma chamada anterior para a operação de receber mensagens ou atualizar mensagens.
- message
-
string
Mensagem para atualizar. Se esse parâmetro estiver indefinido, o conteúdo da mensagem não será atualizado.
- visibilityTimeout
-
number
Especifica o novo valor de tempo limite de visibilidade, em segundos, em relação ao tempo do servidor. O novo valor deve ser maior ou igual a 0 e não pode ser maior que 7 dias. O tempo limite de visibilidade de uma mensagem não pode ser definido como um valor posterior ao tempo de expiração. Uma mensagem pode ser atualizada até que tenha sido excluída ou tenha expirado.
- options
- QueueUpdateMessageOptions
Opções para atualizar a operação da mensagem.
Devoluções
Promise<QueueUpdateMessageResponse>
Dados de resposta para a operação de mensagem de atualização.