概要

最近Azureを触ることが多いのですが、そのたびに「Cosmos DB押し」をよく聞くのでちょっと触ってみることにしました。無償枠もあるようですので、気軽に試せます。

devblogs.microsoft.com

右も左も分からないので、まずは簡単なチュートリアルに沿って作業を進めます。下記のQiitaの記事を参考にしました。

qiita.com

その後は、作成したItemsコンテナに対してnode.jsアプリからアクセスしてみることにします。以下のドキュメントを参考にしました。

docs.microsoft.com

プロジェクト生成

任意の空ディレクトリにてyarn initを実行してプロジェクトを生成します。その後、yarn add @azure/cosmosを実行して必要なライブラリをインストールします。

設定ファイルの用意

config.jsというファイルを作成して接続先やデータベース名やコンテナ名を記述します。参考にしたドキュメントではプライマリーキーも記していましたが、それはあまり行儀が良くないので今回は環境変数で設定することにします。

const config = {
  endpoint: "エントリーポイント",
  databaseId: "ToDoList",
  containerId: "Items",
}

module.exports = config

環境変数の設定

config.jsにて設定しなかったプライマリーキーを環境変数COSMOSDB_KEYに設定するようにします。単純にLinux/macOSであれば、

export COSMOSDB_KEY=プライマリーキー

を実行するだけです。

プログラムの実装

Cosmos DBに対して参照・追加・更新・削除を行うプログラムapp.jsを実装します。こんな感じの実装となりました。

const CosmosClient = require("@azure/cosmos").CosmosClient
const config = require("./config")

const newItem = {
  id: "3",
  category: "fun",
  name: "Cosmos DB",
  description: "Complete Cosmos DB Node.js Quickstart ⚡",
  isComplete: false
}

async function main() {
  const { endpoint, databaseId, containerId } = config
  let key = null
  try {
    if (process.env.COSMOSDB_KEY) {
      key = process.env.COSMOSDB_KEY
    } else {
      throw new Error('環境変数COSMOSDB_KEYが設定されていません')
    }
  } catch (error) {
    console.log(error.message)
    return
  }

  const client = new CosmosClient({ endpoint, key })

  const database = client.database(databaseId)
  const container = database.container(containerId)

  // SELECTを発行してデータを表示する
  const { resources: items } = await container.items.query('SELECT * FROM c').fetchAll()
  items.forEach(item => {
    console.log(`${item.id} - ${item.description}`)
  })

  // 新しいアイテムを追加する
  const { resource: createdItem } = await container.items.create(newItem)
  console.log(`\r\nCreated new item: ${createdItem.id} - ${createdItem.description}\r\n`)

  // 追加したアイテムに対して更新処理を実施する
  const { id } = createdItem
  createdItem.isComplete = true
  const { resource: updatedItem } = await container.item(id).replace(createdItem)
  console.log(`Updated item: ${updatedItem.id} - ${updatedItem.description}`)
  console.log(`Updated isComplete to ${updatedItem.isComplete}\r\n`)

  // データ削除する
  const { resource: result } = await container.item(id).delete()
  console.log(`Deleted item with id: ${id}`)
}

main()

ポイントは以下のとおりです。

async/awaitの使用
- 正直良く分かっていませんが、いい感じに処理待ちをする。
- see. https://developer.mozilla.org/ja/docs/Web/JavaScript/Reference/Statements/async_function
SELECT文のFROMには何を指定してもいい。
- サンプルにはcと指定してあり、？？？だったのですが、何を指定しても良いようです。
  正直、意味はないです。そして何でも構わないです。(aでもbでも関係ない文字でもOKですが、予約語だけはダメです)
  RDBでいうとテーブルを指定するので少し違和感あると思いますが、いわゆる別名だと思っていただければと。
  c = container/collection の別名だと思えばいいと思います。
  — まっぴぃ⊿ (@mappie_kochi) 2020年9月6日

あまり分かっていないのでこれからの課題です。

プログラムの実行

最後に実行です。nodeコマンドで作成したapp.jsを実行させます。

$ node app.js
1 - id = 1
2 - This item is second.

Created new item: 3 - Complete Cosmos DB Node.js Quickstart ⚡

Updated item: 3 - Complete Cosmos DB Node.js Quickstart ⚡
Updated isComplete to true

Deleted item with id: 3