Skip to main content Skills Marketplace Descubra e explore skills de IA criadas pela comunidade.
Instalar com Codex ou Claude Copie este prompt, cole no Codex, Claude ou outro assistente e deixe que ele revise a página da skill e instale para você.
Mostrar detalhes do prompt Um comando direto ignora o prompt de revisão. Verifique a origem antes de executá-lo.
npx skills add https://github.com/BEKO2210/Firstbrain --skill azure-cosmos-tsO comando permanece em uma só linha. Role horizontalmente para revisá-lo antes de copiar.
Prefere uma cópia local? Baixe os arquivos disponíveis atualmente no SkillsMP.
Baixar Zip Baixando... Ocupações relacionadas SOC
Baseado na classificação ocupacional SOC
name azure-cosmos-ts description Azure Cosmos DB JavaScript/TypeScript SDK (@azure/cosmos) for data plane operations. Use for CRUD operations on documents, queries, bulk operations, and container management. type skill created 2026-02-27T00:00:00.000Z domain cloud-infrastructure category azure risk unknown source community tags ["skill","cloud-infrastructure","azure","cosmos"]
@azure/cosmos (TypeScript/JavaScript)
Data plane SDK for Azure Cosmos DB NoSQL API operations — CRUD on documents, queries, bulk operations.
⚠️ Data vs Management Plane
This SDK (@azure/cosmos) : CRUD operations on documents, queries, stored proceduresManagement SDK (@azure/arm-cosmosdb) : Create accounts, databases, containers via ARM
Installation
npm install @azure/cosmos @azure/identity
Current Version : 4.9.0Node.js : >= 20.0.0
Environment Variables
COSMOS_ENDPOINT=https://<account>.documents.azure.com:443/
COSMOS_DATABASE=<database-name>
COSMOS_CONTAINER=<container-name>
COSMOS_KEY=<account-key>
Authentication
AAD with DefaultAzureCredential (Recommended)
import { CosmosClient } from "@azure/cosmos" ;
import { DefaultAzureCredential } from "@azure/identity" ;
const client = new CosmosClient ({
endpoint : process.env .COSMOS_ENDPOINT !,
aadCredentials : new DefaultAzureCredential (),
});
Key-Based Authentication
import { CosmosClient } from "@azure/cosmos" ;
const client = new CosmosClient ({
endpoint : process.env .COSMOS_ENDPOINT !,
key
env
COSMOS_KEY
const
new
CosmosClient
env
COSMOS_CONNECTION_STRING
Resource Hierarchy CosmosClient
└── Database
└── Container
├── Items (documents)
├── Scripts (stored procedures, triggers, UDFs)
└── Conflicts
Core Operations
Database & Container Setup const { database } = await client.databases .createIfNotExists ({
id : "my-database" ,
});
const { container } = await database.containers .createIfNotExists ({
id : "my-container" ,
partitionKey : { paths : ["/partitionKey" ] },
});
Create Document interface Product {
id : string ;
partitionKey : string ;
name : string ;
price : number ;
}
const item : Product = {
id : "product-1" ,
partitionKey : "electronics" ,
name : "Laptop" ,
price : 999.99 ,
};
const { resource } = await container.items .create <Product >(item);
Read Document const { resource } = await container
.item ("product-1" , "electronics" )
.read <Product >();
if (resource) {
console .log (resource.name );
}
Update Document (Replace) const { resource : existing } = await container
.item ("product-1" , "electronics" )
.read <Product >();
if (existing) {
existing.price = 899.99 ;
const { resource : updated } = await container
.item ("product-1" , "electronics" )
.replace <Product >(existing);
}
Upsert Document const item : Product = {
id : "product-1" ,
partitionKey : "electronics" ,
name : "Laptop Pro" ,
price : 1299.99 ,
};
const { resource } = await container.items .upsert <Product >(item);
Delete Document await container.item ("product-1" , "electronics" ).delete ();
Patch Document (Partial Update) import { PatchOperation } from "@azure/cosmos" ;
const operations : PatchOperation [] = [
{ op : "replace" , path : "/price" , value : 799.99 },
{ op : "add" , path : "/discount" , value : true },
{ op : "remove" , path : "/oldField" },
];
const { resource } = await container
.item ("product-1" , "electronics" )
.patch <Product >(operations);
Queries
Simple Query const { resources } = await container.items
.query <Product >("SELECT * FROM c WHERE c.price < 1000" )
.fetchAll ();
Parameterized Query (Recommended) import { SqlQuerySpec } from "@azure/cosmos" ;
const querySpec : SqlQuerySpec = {
query : "SELECT * FROM c WHERE c.partitionKey = @category AND c.price < @maxPrice" ,
parameters : [
{ name : "@category" , value : "electronics" },
{ name : "@maxPrice" , value : 1000 },
],
};
const { resources } = await container.items
.query <Product >(querySpec)
.fetchAll ();
Query with Pagination const queryIterator = container.items .query <Product >(querySpec, {
maxItemCount : 10 ,
});
while (queryIterator.hasMoreResults ()) {
const { resources, continuationToken } = await queryIterator.fetchNext ();
console .log (`Page with ${resources?.length} items` );
}
Cross-Partition Query const { resources } = await container.items
.query <Product >(
"SELECT * FROM c WHERE c.price > 500" ,
{ enableCrossPartitionQuery : true }
)
.fetchAll ();
Bulk Operations
Execute Bulk Operations import { BulkOperationType , OperationInput } from "@azure/cosmos" ;
const operations : OperationInput [] = [
{
operationType : BulkOperationType .Create ,
resourceBody : { id : "1" , partitionKey : "cat-a" , name : "Item 1" },
},
{
operationType : BulkOperationType .Upsert ,
resourceBody : { id : "2" , partitionKey : "cat-a" , name : "Item 2" },
},
{
operationType : BulkOperationType .Read ,
id : "3" ,
partitionKey : "cat-b" ,
},
{
operationType : BulkOperationType .Replace ,
id : "4" ,
partitionKey : "cat-b" ,
resourceBody : { id : "4" , partitionKey : "cat-b" , name : "Updated" },
},
{
operationType : BulkOperationType .Delete ,
id : "5" ,
partitionKey : "cat-c" ,
},
{
operationType : BulkOperationType .Patch ,
id : "6" ,
partitionKey : "cat-c" ,
resourceBody : {
operations : [{ op : "replace" , path : "/name" , value : "Patched" }],
},
},
];
const response = await container.items .executeBulkOperations (operations);
response.forEach ((result, index ) => {
if (result.statusCode >= 200 && result.statusCode < 300 ) {
console .log (`Operation ${index} succeeded` );
} else {
console .error (`Operation ${index} failed: ${result.statusCode} ` );
}
});
Partition Keys
Simple Partition Key const { container } = await database.containers .createIfNotExists ({
id : "products" ,
partitionKey : { paths : ["/category" ] },
});
Hierarchical Partition Key (MultiHash) import { PartitionKeyDefinitionVersion , PartitionKeyKind } from "@azure/cosmos" ;
const { container } = await database.containers .createIfNotExists ({
id : "orders" ,
partitionKey : {
paths : ["/tenantId" , "/userId" , "/sessionId" ],
version : PartitionKeyDefinitionVersion .V2 ,
kind : PartitionKeyKind .MultiHash ,
},
});
const { resource } = await container.items .create ({
id : "order-1" ,
tenantId : "tenant-a" ,
userId : "user-123" ,
sessionId : "session-xyz" ,
total : 99.99 ,
});
const { resource : order } = await container
.item ("order-1" , ["tenant-a" , "user-123" , "session-xyz" ])
.read ();
Error Handling import { ErrorResponse } from "@azure/cosmos" ;
try {
const { resource } = await container.item ("missing" , "pk" ).read ();
} catch (error) {
if (error instanceof ErrorResponse ) {
switch (error.code ) {
case 404 :
console .log ("Document not found" );
break ;
case 409 :
console .log ("Conflict - document already exists" );
break ;
case 412 :
console .log ("Precondition failed (ETag mismatch)" );
break ;
case 429 :
console .log ("Rate limited - retry after:" , error.retryAfterInMs );
break ;
default :
console .error (`Cosmos error ${error.code} : ${error.message} ` );
}
}
throw error;
}
Optimistic Concurrency (ETags)
const { resource, etag } = await container
.item ("product-1" , "electronics" )
.read <Product >();
if (resource && etag) {
resource.price = 899.99 ;
try {
await container.item ("product-1" , "electronics" ).replace (resource, {
accessCondition : { type : "IfMatch" , condition : etag },
});
} catch (error) {
if (error instanceof ErrorResponse && error.code === 412 ) {
console .log ("Document was modified by another process" );
}
}
}
TypeScript Types Reference import {
CosmosClient ,
Database ,
Container ,
Item ,
Items ,
OperationInput ,
BulkOperationType ,
PatchOperation ,
SqlQuerySpec ,
SqlParameter ,
FeedOptions ,
PartitionKeyDefinition ,
PartitionKeyDefinitionVersion ,
PartitionKeyKind ,
ItemResponse ,
FeedResponse ,
ResourceResponse ,
ErrorResponse ,
} from "@azure/cosmos" ;
Best Practices
Use AAD authentication — Prefer DefaultAzureCredential over keysAlways use parameterized queries — Prevents injection, improves plan cachingSpecify partition key — Avoid cross-partition queries when possibleUse bulk operations — For multiple writes, use executeBulkOperationsHandle 429 errors — Implement retry logic with exponential backoffUse ETags for concurrency — Prevent lost updates in concurrent scenariosClose client on shutdown — Call client.dispose() in cleanup
Common Patterns
Service Layer Pattern export class ProductService {
private container : Container ;
constructor (client : CosmosClient this .container = client
.database (process.env .COSMOS_DATABASE !)
.container (process.env .COSMOS_CONTAINER !);
}
async getById (id : string , category : string ): Promise <Product | null > {
try {
const { resource } = await this .container
.item (id, category)
.read <Product >();
return resource ?? null ;
} catch (error) {
if (error instanceof ErrorResponse && error.code === 404 ) {
return null ;
}
throw error;
}
}
async create (product : Omit <Product , "id" >): Promise <Product > {
const item = { ...product, id : crypto.randomUUID () };
const { resource } = await this .container .items .create <Product >(item);
return resource!;
}
async findByCategory (category : string ): Promise <Product []> {
const querySpec : SqlQuerySpec = {
query : "SELECT * FROM c WHERE c.partitionKey = @category" ,
parameters : [{ name : "@category" , value : category }],
};
const { resources } = await this .container .items
.query <Product >(querySpec)
.fetchAll ();
return resources;
}
}
Related SDKs SDK Purpose Install @azure/cosmosData plane (this SDK) npm install @azure/cosmos@azure/arm-cosmosdbManagement plane (ARM) npm install @azure/arm-cosmosdb@azure/identityAuthentication npm install @azure/identity
When to Use This skill is applicable to execute the workflow or actions described in the overview.
Connections
Domain: [[Cloud & Infrastruktur]]Kategorie: [[Microsoft Azure]]Navigation: [[Skills Uebersicht]], [[Home]] 