cosmosdb

package.json

@@ -9,6 +9,7 @@
     "lint": "next lint"
   },
   "dependencies": {
+    "@azure/cosmos": "^4.0.0",
     "@azure/storage-blob": "^12.17.0",
     "dotenv": "^16.4.1",
     "next": "14.1.0",

src/app/api/cosmos/route.ts

@@ -0,0 +1,20 @@
+import { CosmosClient } from "@azure/cosmos";
+import { NextResponse } from "next/server";
+
+const COSMOS_CONNECTION_STRING = process.env.COSMOS_CONNECTION_STRING;
+const client = new CosmosClient(COSMOS_CONNECTION_STRING ?? "");
+const DB_ID = "nhuttudb";
+const CONT_ID = "nhuttucont";
+
+export async function GET(request: Request) {
+  const db = await client.databases.createIfNotExists({ id: DB_ID });
+  const cont = await db.database.containers.createIfNotExists({ id: CONT_ID });
+
+  const res = {
+    status: [db.statusCode, cont.statusCode],
+    endpoints: client.getReadEndpoints(),
+    de: client.getWriteEndpoints(),
+  };
+
+  return NextResponse.json(res);
+}