如何在python中随机访问avro记录？
在Python中随机访问Avro记录，可以通过以下步骤实现：
- 首先，确保已安装
avro库。可以使用以下命令安装：pip install avro-python3 - 导入所需的库和模块：import avro.datafile import avro.io import random
- 打开Avro数据文件并创建一个
DataFileReader对象：reader = avro.datafile.DataFileReader(open('your_avro_file.avro', 'rb'), avro.io.DatumReader()) - 获取Avro数据文件中的记录总数：record_count = reader.block_count
- 生成一个随机索引，用于随机访问记录：random_index = random.randint(0, record_count - 1)
- 使用
seek方法将读取器定位到随机索引处：reader.seek(random_index) - 使用
next方法获取随机索引处的记录：random_record = next(reader) - 关闭读取器：reader.close()
这样，random_record变量将包含随机索引处的Avro记录。
Avro是一种数据序列化系统，用于高效地存储和传输大量结构化数据。它具有以下优势：
- 高性能：Avro使用二进制编码，比文本格式更高效。
- 动态模式：Avro支持动态模式演化，可以在不破坏数据的情况下更新模式。
- 跨语言支持：Avro支持多种编程语言，使得不同语言之间的数据交换更加方便。
Avro在以下场景中得到广泛应用：
- 大数据处理：Avro适用于大规模数据处理和分析，如Hadoop生态系统。
- 消息队列：Avro可用于在消息队列中传输结构化数据。
- 数据存储：Avro可以用作数据存储格式，支持快速读写和查询。
腾讯云提供了一系列与Avro相关的产品和服务，例如：
- 腾讯云数据万象（COS）：提供高可用、高可靠、低成本的对象存储服务，可用于存储Avro数据文件。
- 腾讯云数据工厂（DataWorks）：提供数据集成、数据开发和数据运维的一站式数据服务平台，可用于处理和分析Avro数据。
请注意，本回答仅提供了一种在Python中随机访问Avro记录的方法，并介绍了Avro的一些基本概念、优势和应用场景。在实际应用中，可能还需要根据具体需求进行更详细的配置和使用。
相关·内容
1回答
多目标的快速随机搜索
、、、
目前，我正在使用avro文件将数据记录存储在大小高达50 up的文件中。问题是，除了对文件进行顺序分析之外，我还必须对数据执行随机搜索。avro的问题是，我只能寻求某些同步点，并且必须遍历块，直到找到我寻找的记录为止，但是在某些情况下，这会导致严重的性能损失。我现在的问题是:是否有一种方法可以以不同的格式存储数据，以支持对单个记录的随机搜索，而不需要太多的负担。
限制：
必须放在磁盘上(在一些用例中RAM太小)
需要是二进制的
编程语言: Python，Java，C++是可选的，但是很好
干杯和感谢
浏览 0提问于2015-12-31得票数 0
我有一组index/avro文件(kb/gb)，我使用下面的程序来读取它
import avro.schema
from avro.datafile import DataFileReader
from avro.io import DatumReader, DatumWriter
schema = avro.schema.Parse(open(r"hmd.avsc", "rb").read())
reader = DataFileReader(open(r"data", "rb"), DatumReader())
reader
浏览 16提问于2017-12-15得票数 0
我正在尝试使用Python Avro library ()来读取由JAVA生成的AVRO文件。既然模式已经嵌入到avro文件中，为什么我需要指定一个模式文件？有没有办法自动提取它？
发现了另一个叫做fastavro()的包可以提取avro模式。手册中指定的是python arvo包中的schema文件吗？非常感谢。
浏览 0提问于2014-07-29得票数 13
我的问题是这个。我有一个2GB的快速压缩avro文件，大约有1000条avro记录存储在HDFS上。我知道我可以编写代码“打开这个avro文件”并打印出每个avro记录。我的问题是，在java中是否有一种方法可以说，打开这个avro文件，迭代每个记录并输出到一个文本文件中--在该avro文件中，每个记录的“开始位置”和“结束位置”，这样.我可以有一个java函数调用"readRecord( startposition，endposition)“，它可以使用启动位置和结束位置来快速读取一个特定的avro记录，而不必遍历整个文件？
浏览 0提问于2015-09-11得票数 2
我们试着把这个问题归结为它的本质: python 3中是否有一种方便的方法将avro文件的目录--不仅仅是一个文件--读入一个类似于dataframe的对象？
这个问题涉及一个使用Apache和Spark将avro文件写入HDFS的应用程序。使用pyspark代码，我能够快速计数或转换HDFS上的avro文件。但是，我希望将avro文件的内容作为类似于数据的对象读入内存，作为示例可以执行选择、子查询和计数。据我所知，这是可能的，从吡火花互动shell，但这是操作的Django应用程序，所以这不是一个选项。
我本来希望将python 和结合起来可能是一种选择，但我遇到了递归深度错误，这感觉只限于
浏览 6提问于2017-09-13得票数 2
我能够使用avro-tools-1.7.7.jar获取json数据和avro schema，并输出一个二进制Avro文件，如所示。但是，我希望能够使用Avro python api：以编程方式完成此操作。
在它们的示例中，它们展示了如何一次将一条记录写入二进制avro文件。
import avro.schema
from avro.datafile import DataFileReader, DataFileWriter
from avro.io import DatumReader, DatumWriter
schema = avro.schema.par
浏览 1提问于2017-05-12得票数 2
我有以下要求:我需要每天处理大约20.000个元素(让我们称之为篮子)，这些元素生成100到1.000条记录(让我们把它们称为篮子中的产品)。一个记录大约有10列，每一行大约有500B-1KB大小(总计)。
这意味着，我的产量在5到最大值之间。20米。每天都有记录。
从分析的角度，我需要做一些总结，过滤，特别是显示趋势在多天等。
这个解决方案是基于Python的，我可以使用任何Hadoop、、Google等等。我正在阅读很多关于Avro、Parquet、Hive、HBASE等的文章。
在第一个测试中，我使用SQL Server和两个表(一个用于主要元素，另一个用于所有天产生的项目)进行了一些小
浏览 4提问于2022-12-02得票数 0
回答已采纳
1回答
我们在Microsoft中有一个事件中心实例，它将AVRO格式的数据捕获到blob存储帐户中：
blob名称是container1/my-test-namespace/my-test-eventhub，后面是0、1、2或3，然后是日期。
我可以使用 python类列出blobs：
import os, uuid
from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient, __version__
print("Azure Blob storage v" + __versi
浏览 3提问于2020-09-24得票数 0
回答已采纳
总之，我很幸运地创建了一个带有记录数组的Apache Avro模式，但是当我尝试创建一个记录数组的数组时，python模式解析器失败了。是我做错了什么，还是这是个bug？
{
"type": "record",
"name": "userInfo",
"namespace": "my.example",
"fields": [
{
"name": "ID",
浏览 0提问于2015-11-14得票数 0
这是一个问答，意思是我正在分享我面对的一个问题的解决方案/答案：
问题是来自apache站点的并不完全是最新的，经过一段时间的篡改之后，我设法让这个示例工作起来。
第一次从获得最新版本
转到lang下的py3子文件夹，通过python 3构建项目(阅读更多的)
在python代码所在的文件夹中创建user.avsc。
模式：
{“名称空间”："example.avro“、”类型“：”记录“、”名称“：”用户“、”字段“：[{”名称“：”名称“、”类型“：”字符串“}、{ "favorite_number”、“类型”："int“、"null"}
浏览 4提问于2014-02-19得票数 4
回答已采纳
1回答
假设我有一个Avro文件，我想知道如何添加像timestamp这样的新字段/列来存储python中每条记录的当前系统时间戳。
我试图提取avro模式和附加时间戳field_name，然后添加时间戳值列到数据文件。
我是python和avro的新手。有没有人能帮我告诉我该怎么做。
浏览 4提问于2018-10-22得票数 0
1回答
我无法为特定模式生成数据，也无法理解原因。代码中包含为字典的示例数据是直接使用汇合的“avro-随机生成器”创建的，因此示例数据必须是正确的，因为它是直接从模式派生的。模式注册表和Avro随机生成器都是合流工具，因此它们的工具不可能产生与它们的模式注册表不兼容的示例数据。
这是模式：
{
"type": "record",
"name": "schemaV1",
"namespace": "net.avro.schemaV1",
"doc": "",
浏览 10提问于2019-10-15得票数 0
我正在使用Apache Avro 1.8.2读取一个大的avro文件。但是，我想跳过前'N‘个记录或处理文件的5个线程的个别部分。
有没有什么简单的方法可以在avro文件中查找，而不会导致数据损坏，而不是顺序地遍历每条记录？我相信它是可拆分的格式，但我不确定python avro模块是否支持安全地跳到特定位置。
目前我所能做的就是逐行处理：
reader = DataFileReader(open("users.avro", "rb"), DatumReader())
i = 0
for user in reader:
i += 1
if
浏览 6提问于2018-07-06得票数 4
1回答
我想知道Avro是否支持随机访问或查询。例如，如果我创建了一个名为B.avro的Avro文件，其中包含两个二进制文件X.png和Y.png，是否可以直接访问Y.png？在不需要遍历整个文件的情况下，如果有一种方法可以使用文件键直接访问文件内容，那就太好了。
如果没有，有没有其他的数据结构可以让我在hadoop环境sequenceFiles中这样做呢？我基本上使用Avro作为一种在hadoop中处理大量小文件的方法，但我也想查询这些文件，这使得在较大的集合中存储它们变得困难。
谢谢。
浏览 2提问于2013-07-05得票数 1
1回答
我有个问题。我创建了以下avro模式：
{
"namespace": "foo",
"fields": [
{
"type": [
"string",
"null"
],
"name": "narf"
},
{
浏览 0提问于2015-05-15得票数 1
通过在Hive中启用事务，我们可以更新记录。假设我用的是AVRO格式的蜂巢表。
如何处理更新AVRO文件并在不同服务器上再次复制这些文件(因为复制因子为3 )。
我找不到一篇很好的文章来解释这一点，以及在蜂巢中使用ACID的后果。由于建议HDFS不更新或只追加文件，因此如何在工作之间更新记录。
请给我建议。
浏览 3提问于2017-05-23得票数 1
回答已采纳
1回答
我正在尝试使用提供的"AvroStorage“加载函数将Avro数据文件加载到pig中。数据是从一个python脚本生成的，该脚本使用python的avro库将文本数据转换为avro格式。即使我只是试着跑步
out = LOAD "path/to/file.avro" using AvroStorage();
我得到了错误
java.lang.ClassCastException: org.apache.avro.util.Utf8 cannot be cast to java.lang.String
我使用avro版本1.7.7来创建数据。
我不知道如何判断pig函数
浏览 0提问于2015-02-26得票数 1
我在java中创建了ClassA，它有一些自定义注释，我不能创建avro记录的一部分。我想在avro中定义协议rpc来返回自定义的java类。
类似于：
@namespace("org.test.avro.service") protocol TestService {
org.test.avro.domain.ClassA methodA(); }
它显示org.apache.avro.compiler.idl.ParseException:未定义的名称'org.test.avro.domain.ClassA‘
浏览 4提问于2016-05-24得票数 0
我试图用Python解释Debezium在Kafka中存储的Avro记录。
{
"name": "id",
"type": {
"type": "bytes",
"scale": 0,
"precision": 64,
"connect.version": 1,
浏览 12提问于2017-10-23得票数 5
我很好奇，这是一种处理Avro Python的方式，就像在Java或C++实现中一样。
根据官方的Avro Python文档，我必须在运行时提供一个Avro模式来编码/解码数据。但是，这是一种像在Java/C++中那样使用代码生成器的方法吗？
浏览 1提问于2015-10-07得票数 8
2回答
我尝试使用avro-python3 (向后兼容性)重新创建一个模式演化案例。
我有两个模式：
import avro.schema
from avro.datafile import DataFileReader, DataFileWriter
from avro.io import DatumReader, DatumWriter
schema_v1 = avro.schema.Parse("""
{
"type": "record",
"namespace": "com.example&#
浏览 1提问于2019-05-07得票数 1
3回答
我正在写一个使用python的spark作业。然而，我需要读入一大堆avro文件。
是我在Spark的example文件夹中找到的最接近的解决方案。但是，您需要使用spark-submit提交此python脚本。在spark-submit的命令行中，你可以指定driver- class，在这种情况下，所有的avrokey，avrovalue类都会被定位。
avro_rdd = sc.newAPIHadoopFile(
path,
"org.apache.avro.mapreduce.AvroKeyInputFormat",
浏览 5提问于2015-04-21得票数 14
回答已采纳
3回答
在avro数据读取器对象上有一个for循环。
for i in reader:
print i
然后，我在for语句中得到了一个unicode解码错误，所以我想忽略该特定记录。所以我做了这个
try:
for i in reader:
print i
except:
pass
但这种情况不会继续下去。我怎样才能克服这个问题？
编辑:添加错误跟踪
Traceback (most recent call last):
File "modify.py", line 22, in <module>
for reco
浏览 5提问于2015-05-29得票数 3
回答已采纳
1回答
我有一个avro文件，文件名为test.avsc，模式为：
{
"namespace": "test",
"type": "record",
"name": "test.schema",
"fields": [
{ "name": "device", "type": ["null", "string"] , "default" : null }
浏览 19提问于2021-03-16得票数 0
回答已采纳
我有一个简单的Kafka阅读器类。我真的不记得我是从哪里得到这个代码的。可能是我发现的，也可能是我之前的自己从不同的例子中创建的。无论哪种方式，它都可以让我快速阅读卡夫卡主题。
class KafkaStreamReader():
def __init__(self, schema_name, topic, server_list):
self.schema = get_schema(schema_name)
self.topic = topic
self.server_list = server_list
self.consumer = KafkaConsu
浏览 0提问于2018-07-26得票数 0
我有一个Scala类，它用getter和setter包装avro记录。使用Jython允许用户编写python脚本来处理Avro记录，并最终对新处理的记录执行json.dumps。
问题是，如果用户想从记录中获取作为Array的值，解释器会抱怨对象不能JSON序列化。
import json
json.dumps(<AClass>.getArray('myArray'))
在运行时，任何给定的python脚本都可以使用AClass。Scala AClass：
class AClass {
def getArray(fieldName: String): Arra
浏览 6提问于2021-05-12得票数 1
我们正在努力将Apache Storm与Kafka的Confluent框架集成在一起。我们正在使用名为"Pyleus“的storm的python包装器
我们设置了一个Confluent-Kafka JDBC连接器来监视数据库表，每当DB中发生变化时，新记录就会以Avro格式作为Kafka消息发送。
在Pyleus bolt中，我们能够获得Kafka消息，但是，我们不能将其反序列化为JSON。
我们使用了两个名为"avro_json_serializer“和"avro”的python-Avro模块。当我尝试反序列化我放在一起的简单Avro文件时，它们会起作用。
Kafka
浏览 1提问于2016-03-01得票数 0
我有一个AVRO模式，目前在单个avsc文件，如下所示。现在我想将地址记录移动到一个不同的公共avsc文件中，该文件应该从许多其他avsc文件中引用。因此，客户和地址将是单独的avsc文件。怎样才能将它们分开，并有客户的avsc文件引用地址avsc文件。另外，如何使用python处理这两个文件。我目前正在使用python3中的fast avro来处理单个avsc文件，但可以使用python3或pyspark中的任何其他实用程序。 文件名- customer_details.avsc [
{
"type": "record",
"name
浏览 48提问于2020-08-17得票数 2
回答已采纳
我有一份档案。我想使用nodejs打开和读取它的模式，并遍历它的记录。怎么做？我在nodejs中看到的avro库似乎要求您传递模式，而不是从.avro文件中获取模式。另外，我希望能够支持数组，因为似乎不存在这样的节点库( not Io)。
我的avro/avroschema包含：
嵌套字段{a:{suba: vala，subb: vala}}。
数组字段{a:"A“、"B"}。节点-avro-io不工作。
节点-avro-io中的错误：
Avro Invalid Schema Error: Primitive type must be one of: [
浏览 9提问于2015-03-24得票数 3
3回答
我有一个拼花文件，我通过转换一些avro数据文件。该文件包含复杂的记录。此外，我还有这些记录的avro模式以及等效的parquet模式(我在转换文件时得到了它)。我想做一个蜂箱表，用拼花文件做后背。
因为我的记录模式有很多字段，手动声明与这些字段对应的单元列是非常困难和容易出错的。这就是为什么我希望hive使用记录的parquet模式来定义表的列，就像AvroSerDe使用avro模式定义表列一样。这是ParquetSerDe支持的吗？我怎么能这么做？
我知道可能的解决办法，首先可以使用avro模式定义avro支持的表，然后使用CTAS语句来创建parquet表。但是，如果模式有联合，这是行不
浏览 21提问于2015-01-12得票数 3
回答已采纳
我正在尝试使用to_avro()函数来创建Avro记录。但是，我不能对多列进行编码，因为一些列在编码后就会丢失。重现问题的一个简单示例： val schema = StructType(List(
StructField("entity_type", StringType),
StructField("entity", StringType)
))
val rdd = sc.parallelize(Seq(
Row("PERSON", "John Doe")
))
val df = sqlContext.create
浏览 23提问于2020-12-08得票数 0
2回答
我正在尝试让Python解析Avro模式，如下所示……
from avro import schema
mySchema = """
{
"name": "person",
"type": "record",
"fields": [
{"name": "firstname", "type": "string"},
{"name": "lastnam
浏览 0提问于2012-08-02得票数 37
回答已采纳
我试图在HDInsight星系团中读取一个avro文件，但是
u'Failed to find data source: com.databricks.spark.avro. Please find an Avro package at http://spark.apache.org/third-party-projects.html;'
Traceback (most recent call last):
File "/usr/hdp/current/spark2-client/python/pyspark/sql/readwriter.py", line
浏览 1提问于2018-04-01得票数 6
1回答
我试着在Hadoop中使用to...figure这个例子。
什么是最好的文件格式Avro或SequenceFile，以防将图像存储在HDFS中，然后用Python处理它们？
SequenceFile是面向关键值的，所以我认为Avro文件会工作得更好吗？
浏览 2提问于2014-06-07得票数 1
回答已采纳
3回答
我有一个AVRO文件(由JAVA创建)，它似乎是hadoop/mapreduce的某种压缩文件，我想‘解压缩’(反序列化)到一个平面文件。每行每条记录。
我了解到有一个用于python的，并且我正确地安装了它。并运行该示例以读取AVRO文件。然而，它出现了下面的错误，我想知道在阅读最简单的示例时发生了什么？有人能帮我解释一下下面的错误吗？
>>> reader = DataFileReader(open("/tmp/Stock_20130812104524.avro", "r"), DatumReader())
Traceback (most
浏览 2提问于2013-08-27得票数 4
回答已采纳
我希望用元数据头(即嵌套模式)为每个记录(csv)创建一个avro消息。
我正在使用Python3.4。我已经下载了必需的模块，即avro-python3 3。我有记录数据的形式csv与它的头。
基本上，我有创建所需消息和元数据头的代码。
我的AVSC文件(仅样本)：
Schema: {"name": "person","type": "record","fields": [{"name": "address","type": {"type" : &#
浏览 0提问于2019-02-22得票数 0
1回答
我尝试过使用链接从linux访问windows机器外壳。对我来说是正确的。在使用时，我可以使用ls或dir windows目录。但我不能执行python可执行文件。它显示在错误下面。
$ C:\\Python27\\python.exe
-bash: C:\Python27\python.exe: command not found
现在我收到了新的错误后，一些改变的答复，我已经提到了整个情况下。
Sanjayb@MA-SANJAYB-PC /cygdrive/d
$ /cygdrive/c/Python27/python.exe ./scripts/Python_Scripts/avro_d
浏览 4提问于2015-05-06得票数 0
我正在编写一个spark应用程序，它接收avro记录。我正在将avro记录转换为Spark DataFrame (df)对象。df包含以秒为单位的时间戳属性。(纪元时间)
我想用日期列替换秒列。如何做到这一点？
我的代码片段是：
val df = sqlContext.read.avro("/root/Work/PixelReporting/input_data/pixel.avro")
val pixelGeoOutput = df.groupBy("current_time", "pixel_id", "geo_id", &#
浏览 2提问于2016-05-03得票数 0
我有一个带有RabbitMQ绑定的(Elmhurst发行版)拆分器。我正在尝试更新它，以便它将使用Avro模式作为有效负载。我得到了一个转换异常，这使它看起来像是Avro转换器没有被调用，而JSON转换器获取消息并在其上运行。
由: org.springframework.messaging.converter.MessageConversionException:无法写入JSON:而不是地图：{“类型”：“记录”，“名称”：“SkinnyMessage”，“命名空间”：“com.example.avro”，“doc”：“用于传递消息对象的引用的轻型消息”，“字段”：{“name”：“id”
浏览 1提问于2018-08-23得票数 0
回答已采纳
我已经在线查看了avro文档和几个示例(以及类似的StackOverflow问题)。然后，我尝试定义一个avro模式，并且不得不逐步退出字段来确定我的问题是什么(来自python中avro库的错误消息并不像人们希望的那样有帮助)。我有一个想要转换为Avro的JSON文档，我需要为此指定一个模式(使用avro-tools从json生成模式不能像预期的那样工作，并且在尝试将json转换为avro时产生一个AvroTypeException )。我使用的是Avro版本1.7.7。下面是我想为其定义avro模式的JSON文档：
{
"method": "Do_Thing&#
浏览 16提问于2016-09-13得票数 1
回答已采纳
3回答
当试图编写avro时，我得到以下错误：
org.apache.spark.SparkException: Job aborted due to stage failure: Task 7 in stage 35.0 failed 1 times, most recent failure: Lost task 7.0 in stage 35.0 (TID 110, localhost): java.lang.ClassCastException: java.util.HashMap cannot be cast to org.apache.avro.mapred.AvroWrapper
我在一个
浏览 3提问于2015-04-14得票数 18
回答已采纳
1回答
我有一条管道可以解析来自AVRO文件的记录。
我需要将输入的记录分成500个条目，以便调用一个同时接受多个输入的API。
有什么方法可以用Python来完成吗？
浏览 0提问于2017-07-29得票数 4
回答已采纳
1回答
我正在尝试创建一个基于现有模式的Avro，但在使用位于的教程中的语法时遇到错误。控制台说'bytes‘对象没有'to_json’属性，但它位于Avro库的深层。有什么好的解决方法或方法来修复这个错误吗？
完全错误：
Traceback (most recent call last):
File "build_data.py", line 15, in <module>
al.create_avro(logs)
File "AppLog.py", line 57, in create_avro
writer = DataFileWrit
浏览 0提问于2017-02-27得票数 1
我想创建一个avro模式，其中一条记录的名称中会有一个特殊字符。 [{
"name": "Example",
"type": "record",
"namespace": "com.example",
"fields": [
{
"name": "@example",
"type": "string"
}
]}] 返回错误： Execution default of goal org.apach
浏览 47提问于2021-05-01得票数 0
1回答
我有一个avro文件，我想根据一些条件过滤掉记录。如何在读取时从文件中删除记录？
from fastavro import reader
with open("D:///temp/load_data.avro", 'rb') as fo:
avro_reader = reader(fo)
for record in avro_reader:
if(record['NAME'] == ''):
//remove
浏览 14提问于2020-05-05得票数 0
我成功地在Python中安装了Apache。然后，我尝试按照下面的说明将Avro文件读入Python。
https://avro.apache.org/docs/1.8.1/gettingstartedpython.html
我在一个目录中有一堆Avros，它已经在Python中被设置为正确的路径。这是我的代码：
import avro.schema
from avro.datafile import DataFileReader, DataFileWriter
from avro.io import DatumReader, DatumWriter
reader = DataFileRea
浏览 8提问于2016-11-22得票数 3
回答已采纳
我使用avro1.8.2 + python3.7 (pip install avro-python3)来处理AVRO格式。 以下是来自AVRO website的示例代码 import avro.schema
from avro.datafile import DataFileReader, DataFileWriter
from avro.io import DatumReader, DatumWriter
schema = avro.schema.parse(open("user.avsc", "rb").read())
writer = DataFil
浏览 10提问于2019-03-03得票数 2
回答已采纳
我已经访问了Apache集群，并获得了一个描述Apache消息序列化格式的文件。我正在用python编写一个小的测试使用者，在试图解析模式时，我得到了以下错误：
SchemaParseException: Type property "{u'items': u'com.myapp.avromsg.common.MilestoneField', u'type': u'array'}" not a valid Avro schema: Items schema (com.myapp.avromsg.common.Mil
浏览 0提问于2018-03-23得票数 0
回答已采纳
我找不到工具来检查avro模式是否遵循avro规范。我怎样才能检查这个？
我已经生成了一个300kB的avro模式，但我不知道它的语法是否符合avro规范。avro规范有相当多的怪癖，比如命名约定、在记录中处理记录以及其他怪癖。
更重要的是，如果我使用根据avro模式验证json的工具来尝试我的avro模式，我会得到一个未指明的错误或崩溃。
有没有工具可以验证avro模式本身？
浏览 1提问于2019-02-13得票数 1
我正在用Avro在C#中序列化数据。然后，我使用Python对其进行反序列化。让我们假设我有以下模式：
{
"type": "record",
"name": "ClassXY",
"fields" : [{"name": "x", "type": "double"}]
}
如果我的记录是"ClassXY“类型，我如何在python端检查？我能以某种方式访问"name“的值(ClassXY)吗？
浏览 4提问于2017-02-02得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
