データの変更を監視

Watch()メソッドを使用して、 Collection 、 Database 、またはClientで変更ストリームを開くことができます。

例

Tip

この例の実行方法については、「の使用例」をお読みください。

次の例では、 restaurantsコレクションの変更ストリームを開き、挿入されたドキュメントを出力します。

coll := client.Database("sample_restaurants").Collection("restaurants")
// Creates instructions to watch for insert operations
pipeline := mongo.Pipeline{bson.D{{"$match", bson.D{{"operationType", "insert"}}}}}
// Creates a change stream that receives change events
cs, err := coll.Watch(context.TODO(), pipeline)
if err != nil {
	panic(err)
}
defer cs.Close(context.TODO())
fmt.Println("Waiting For Change Events. Insert something in MongoDB!")
// Prints a message each time the change stream receives an event
for cs.Next(context.TODO()) {
	var event bson.M
	if err := cs.Decode(&event); err != nil {
		panic(err)
	}
	output, err := json.MarshalIndent(event["fullDocument"], "", "    ")
	if err != nil {
		panic(err)
	}
	fmt.Printf("%s\n", output)
}
if err := cs.Err(); err != nil {
	panic(err)
}

が完全に実行可能な例を表示します。

期待される結果

完全な例を実行したら、別の shell でドキュメントの挿入の使用例を実行します。挿入操作を実行すると、次の出力が表示されます。

// results truncated
{
  "_id": ...,
  "name": "8282",
  "cuisine": "Korean"
}

重要

終了したら、ターミナルを閉じてこの使用例をシャットダウンしてください。

詳細情報

変更ストリームを開き、潜在的なエラーを処理するの詳細については、以下を参照してください。

変更ストリームの基礎ページ
MongoDB Server マニュアルChange Streams のドキュメント

API ドキュメント

Watch()

戻る

一括操作の実行

ドキュメントをカウント