Debezium模式不为空和主键信息

问题描述

Debezium Schema没有不包含null和主键信息。我正在使用debezium模式构造redshift create table命令。在文档中找不到与此有关的任何信息。

type DebeziumColumn struct {
    Name        string `json:"name"`
    Type        string `json:"type"`
    Default     string `json:"default"`
    NotNull     bool   `json:"notnull"`
    PrimaryKey  bool   `json:"primarykey"`
}

能否从下面的Debezium模式中找到NotNull和PrimaryKey？

架构

{
   "type":"record","name":"Envelope","namespace":"datapipe.inventory.customers","fields":[
      {
         "name":"before","type":[
            "null",{
               "type":"record","name":"Value","fields":[
                  {
                     "name":"id","type":"int"
                  },{
                     "name":"first_name","type":"string"
                  },{
                     "name":"last_name",{
                     "name":"email","type":"string"
                  }
               ],"connect.name":"datapipe.inventory.customers.Value"
            }
         ],"default":null
      },{
         "name":"after","Value"
         ],{
         "name":"source","type":{
            "type":"record","name":"Source","namespace":"io.debezium.connector.MysqL","fields":[
               {
                  "name":"version","type":"string"
               },{
                  "name":"connector",{
                  "name":"name",{
                  "name":"ts_ms","type":"long"
               },{
                  "name":"snapshot","type":[
                     {
                        "type":"string","connect.version":1,"connect.parameters":{
                           "allowed":"true,last,false"
                        },"connect.default":"false","connect.name":"io.debezium.data.Enum"
                     },"null"
                  ],"default":"false"
               },{
                  "name":"db",{
                  "name":"table","type":[
                     "null","string"
                  ],"default":null
               },{
                  "name":"server_id",{
                  "name":"gtid",{
                  "name":"file",{
                  "name":"pos",{
                  "name":"row","type":"int"
               },{
                  "name":"thread","long"
                  ],{
                  "name":"query","default":null
               }
            ],"connect.name":"io.debezium.connector.MysqL.source"
         }
      },{
         "name":"op","type":"string"
      },{
         "name":"ts_ms","long"
         ],{
         "name":"transaction","name":"ConnectDefault","namespace":"io.confluent.connect.avro",{
                     "name":"total_order","type":"long"
                  },{
                     "name":"data_collection_order","type":"long"
                  }
               ]
            }
         ],"default":null
      }
   ],"connect.name":"datapipe.inventory.customers.Envelope"
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）