Data Formats

Raw JSON

Raw JSON は、string として記述された JSON オブジェクトで構成されるデータ形式です。 次のように、サンプル ドキュメントを Raw JSON で表します。

"{\"company\":\"MongoDB\"}"

ソース コネクタまたは Sink コネクタで 変換を指定する場合は、Raw を使用します。JSONstringstring変換を指定するコネクタ構成を表示するには、変換ガイドを参照してください。

BSON

BSON は、JSON のようなオブジェクト用のバイナリ直列化エンコーディングです。 BSON はサンプル ドキュメントを次のようにエンコードします。

\x1a\x00\x00\x00\x02company\x00\x08\x00\x00\x00MongoDB\x00\x00

connectorは BSON 形式を使用して MongoDB 配置でドキュメントを送受信します。

BSON の詳細について は、 BSON 仕様 を参照してください。

JSON Schema

JSON schema は、JSON オブジェクトのスキーマを指定するための構文です。 スキーマは、そのトピックの有効な値を定義する Apache Kafka トピック に添付された定義です。

次のように、JSON schema を含むサンプルドキュメントのスキーマを指定できます。

{
   "$schema":"http://json-schema.org/draft-07/schema",
   "$id":"unique id",
   "type":"object",
   "title":"Example Schema",
   "description":"JSON Schema for the sample document.",
   "required":[
      "company"
   ],
   "properties":{
      "company":{
         "$id":"another unique id",
         "type":"string",
         "title":"Company",
         "description":"A field to hold the name of a company"
      }
   },
   "additionalProperties":false
}

コネクタに JSON schema 変換 を適用するときに、JSON schema を使用します。 JSON schema 変換を指定するコネクター構成を表示するには、「変換」ガイドを参照してください。

詳細については、 JSON schema の公式ウェブサイトを参照してください。

Avro Schema

Avro schema は、JSON ベースのスキーマ定義構文です。 Atlas スキーマは、次のグループのデータ型の仕様をサポートしています。

• プリミティブ タイプ

• 複雑な型

• 論理タイプ

次のように、サンプル ドキュメント用の Avro スキーマを構築できます。

{
  "type": "record",
  "name": "example",
  "doc": "example documents have a company field",
  "fields": [
    {
      "name": "company",
      "type": "string"
    }
  ]
}

MongoDB Kafka ソース コネクタのスキーマを定義するときは、Avro スキーマを使用します。

すべての Avro スキーマ タイプのリストについては、 Apache Avro 仕様 を参照してください。

平均バイナリ エンコーディング

Atlas は、 Avro スキーマによって定義された JSON オブジェクトのバイナリ直列化エンコーディングを指定します。

上記のAvro スキーマを使用すると、次のように Atlas バイナリ エンコーディングでサンプル ドキュメントを表すことができます。

\x0eMongoDB

ソース コネクタまたは シンク コネクタで Atlas 変換を指定する場合は、Avro バイナリ エンコーディングを使用します。 Atlas 変換を指定するコネクター構成を表示するには、「変換」ガイドを参照してください。

Atlas バイナリ エンコーディングの詳細について は、 Atlas 仕様のこのセクションを参照してください。