将avro生成的对象序列化为json时的JsonMappingException

Question

我使用avro工具从avsc文件生成java类，使用：

java.exe -jar avro-tools-1.7.7.jar compile -string schema myfile.avsc 

然后，我试图通过ObjectMapper将这些对象序列化为json，但总是得到一个JsonMappingException，上面写着“不是枚举”或“不是联合”。在我的测试中，我使用其生成器或构造函数创建生成的对象。我对不同类的对象有这样的例外。。。

示例代码：

ObjectMapper serializer = new ObjectMapper(); // com.fasterxml.jackson.databind
serializer.register(new JtsModule()); // com.bedatadriven.jackson.datatype.jts
...
return serializer.writeValueAsBytes(avroConvertedObject); // => JsonMappingException

我还使用：serializer尝试了许多配置。配置（…）但还是失败了。版本：Java 1.8、jackson datatype jts 2.3、jackson core 2.6.5、jackson databind 2.6.5、jackson annotations 2.6.5

有什么建议吗？谢谢

Answer 1

我的req'ts发生了变化，我被告知需要将Avro对象直接转换为JSON，而不保留任何元数据。我在这里的另一个答案是指定一个方法convertToJsonString将整个Avro对象转换为JSON，以便使用反编码器可以将原始Avro对象重新创建为Avro对象。这不是我的mgt。我不再需要了，所以我又回到了原来的画板上。

作为万福玛利亚通行证，我尝试使用Gson，它可以做我现在必须做的事情。很简单：

 Gson gson = new Gson();
 String theJsonString = gson.toJson(object_ur_converting);

你就完了。

Answer 2

在以下位置找到代码示例后https://www.programcreek.com/java-api-examples/?api=org.apache.avro.io.JsonEncoder我编写了一个方法，可以将任何给定的Avro对象（它们扩展了GenericRecord）转换为Json字符串。代码：

import org.apache.avro.generic.GenericDatumWriter;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumWriter;
import org.apache.avro.io.EncoderFactory;
import org.apache.avro.io.JsonEncoder;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStream;

// ... Class header etc. ...

public static <T extends GenericRecord> String convertToJsonString(T event) throws IOException {

    String jsonstring = "";

    try {
        DatumWriter<T> writer = new GenericDatumWriter<T>(event.getSchema());
        OutputStream out = new ByteArrayOutputStream();
        JsonEncoder encoder = EncoderFactory.get().jsonEncoder(event.getSchema(), out);
        writer.write(event, encoder);
        encoder.flush();
        jsonstring = out.toString();
    } catch (IOException e) {
        log.error("IOException occurred.", e);
        throw e;
    }

    return jsonstring;
}

Answer 3

如果架构成员确实是这种情况（我们没有看到完整的错误消息），那么您可以将其关闭。我用mixin来做这件事，就像这样：

import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import org.apache.avro.Schema;
import org.junit.Test;

import java.io.File;
import java.io.IOException;

public class AvroGenerTests
{
  abstract class IgnoreSchemaProperty
  {
    // You have to use the correct package for JsonIgnore,
    // fasterxml or codehaus
    @JsonIgnore abstract void getSchema();
  }

  @Test
  public void writeJson() throws IOException {
    BookAvro b = BookAvro.newBuilder()
      .setTitle("Wilk stepowy")
      .setAuthor("Herman Hesse")
      .build();
    ObjectMapper om = new ObjectMapper();
    om.enable(SerializationFeature.INDENT_OUTPUT);
    om.addMixIn(BookAvro.class, IgnoreSchemaProperty.class);
    om.writeValue(new File("plik_z_gen.json"), b);
  }
}