6

我在这里找到了一些代码https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-dotnet-avro-serialization#Scenario2与我需要的相反：

//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 Schema 字符串。

原因：

我只想维护 C# 模型并使用 Confluent 的 Schema Registry 自动注册这些模型。要向架构注册表注册，架构需要采用 JSON AVRO 格式（就像Schema上面一样）。

我不希望同时定义 JSON 和 C# 模型。如果我必须维护一个，我宁愿拥有一个 C# 模型。

4

3 回答 3

6

我在 中找到了我要找的东西Microsoft.Hadoop.Avro.AvroSerializer。

AvroSerializer.Create<Demo>().WriterSchema.ToString();
// > {"type":"record","name":"pubsub.demo.Demo","fields"[{"name":"value","type":"long"}]}
于 2017-07-26T23:37:13.077 回答
2

解决方案也可以是：

string schema = AvroConvert.GenerateSchema(typeof(Demo));

来自https://github.com/AdrianStrugala/AvroConvert

于 2020-04-15T06:20:38.040 回答
0

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

于 2021-03-10T18:28:37.557 回答