可以将 C# 模型序列化为 AVRO JSON 模式吗?
Can a C# model be serialized as an AVRO JSON Schema?
我在这里 https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-dotnet-avro-serialization#Scenario2 找到了一些代码,可以实现我需要的 reverse:
//Define the schema in JSON
const string Schema = @"{
""type"":""record"",
""name"":""Microsoft.Hadoop.Avro.Specifications.SensorData"",
""fields"":
[
{
""name"":""Location"",
""type"":
{
""type"":""record"",
""name"":""Microsoft.Hadoop.Avro.Specifications.Location"",
""fields"":
[
{ ""name"":""Floor"", ""type"":""int"" },
{ ""name"":""Room"", ""type"":""int"" }
]
}
},
{ ""name"":""Value"", ""type"":""bytes"" }
]
}";
//Create a generic serializer based on the schema
var serializer = AvroSerializer.CreateGeneric(Schema);
我想使用我创建的模型:
[DataContract(Name = "Demo", Namespace = "pubsub.demo")]
public class Demo
{
[DataMember(Name = "value")]
public long Value { get; set; }
}
...并将此 C# 模型序列化为 JSON AVRO 架构字符串。
原因:
我只想维护 C# 模型并使用 Confluent 的架构注册表自动注册这些模型。要向模式注册表注册,模式需要采用 JSON AVRO 格式(就像上面的 Schema
)。
我不想同时定义 JSON 和 C# 模型。如果我必须维护一个,我宁愿有一个 C# 模型。
我在 Microsoft.Hadoop.Avro.AvroSerializer
中找到了我要找的东西。
AvroSerializer.Create<Demo>().WriterSchema.ToString();
// > {"type":"record","name":"pubsub.demo.Demo","fields"[{"name":"value","type":"long"}]}
解决方案也可以是:
string schema = AvroConvert.GenerateSchema(typeof(Demo));
Chr.Avro 提供了一个 CLI,让您可以双向使用 - C# 类型到 Avro 模式,Avro 模式到 C# 类型。
来自文档:
dotnet avro create --type ExampleNamespace.ExampleLibrary.ExampleClass --assembly bin/Debug/netstandard2.0/ExampleNamespace.ExampleLibrary.dll
https://engineering.chrobinson.com/dotnet-avro/guides/cli-create
我在这里 https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-dotnet-avro-serialization#Scenario2 找到了一些代码,可以实现我需要的 reverse:
//Define the schema in JSON
const string Schema = @"{
""type"":""record"",
""name"":""Microsoft.Hadoop.Avro.Specifications.SensorData"",
""fields"":
[
{
""name"":""Location"",
""type"":
{
""type"":""record"",
""name"":""Microsoft.Hadoop.Avro.Specifications.Location"",
""fields"":
[
{ ""name"":""Floor"", ""type"":""int"" },
{ ""name"":""Room"", ""type"":""int"" }
]
}
},
{ ""name"":""Value"", ""type"":""bytes"" }
]
}";
//Create a generic serializer based on the schema
var serializer = AvroSerializer.CreateGeneric(Schema);
我想使用我创建的模型:
[DataContract(Name = "Demo", Namespace = "pubsub.demo")]
public class Demo
{
[DataMember(Name = "value")]
public long Value { get; set; }
}
...并将此 C# 模型序列化为 JSON AVRO 架构字符串。
原因:
我只想维护 C# 模型并使用 Confluent 的架构注册表自动注册这些模型。要向模式注册表注册,模式需要采用 JSON AVRO 格式(就像上面的 Schema
)。
我不想同时定义 JSON 和 C# 模型。如果我必须维护一个,我宁愿有一个 C# 模型。
我在 Microsoft.Hadoop.Avro.AvroSerializer
中找到了我要找的东西。
AvroSerializer.Create<Demo>().WriterSchema.ToString();
// > {"type":"record","name":"pubsub.demo.Demo","fields"[{"name":"value","type":"long"}]}
解决方案也可以是:
string schema = AvroConvert.GenerateSchema(typeof(Demo));
Chr.Avro 提供了一个 CLI,让您可以双向使用 - C# 类型到 Avro 模式,Avro 模式到 C# 类型。
来自文档:
dotnet avro create --type ExampleNamespace.ExampleLibrary.ExampleClass --assembly bin/Debug/netstandard2.0/ExampleNamespace.ExampleLibrary.dll
https://engineering.chrobinson.com/dotnet-avro/guides/cli-create