如何从同时列出数据和模式JSON文件创建Spark-SQL数据帧
从同时列出数据和模式JSON文件创建Spark-SQL数据帧，可以通过以下步骤实现：
- 首先，确保你已经安装了Apache Spark，并且已经设置好了Spark的环境变量。
- 创建一个JSON文件，其中包含数据和模式信息。JSON文件应该具有以下结构：
- 创建一个JSON文件，其中包含数据和模式信息。JSON文件应该具有以下结构：
- 其中，data字段包含实际的数据，schema字段定义了数据的模式。
- 在Spark应用程序中，使用以下代码加载JSON文件并创建数据帧：
- 在Spark应用程序中，使用以下代码加载JSON文件并创建数据帧：
- 这段代码首先使用SparkSession对象创建一个Spark应用程序的入口点。然后，使用
spark.read.json()方法加载JSON文件并将其解析为DataFrame。接下来，使用select()方法选择"data"和"schema"字段，并使用createDataFrame()方法创建数据帧。 - 现在，你可以对数据帧执行各种操作，如过滤、聚合、排序等。例如：
- 现在，你可以对数据帧执行各种操作，如过滤、聚合、排序等。例如：
- 这些代码展示了如何显示数据帧的内容、如何过滤数据帧、如何聚合数据帧以及如何排序数据帧。你可以根据具体需求进行相应的操作。
这样，你就可以从同时列出数据和模式的JSON文件创建Spark-SQL数据帧了。请注意，上述代码中的路径和字段名称应根据实际情况进行修改。
相关·内容
我在使用制表符分隔值(TSV)和逗号分隔值(CSV)文件时使用Spark 2.0。我希望将数据加载到Spark-SQL数据帧中，在读取文件时，我希望完全控制模式。我不希望Spark从文件中的数据中猜测模式。
如何将TSV或CSV文件加载到Spark SQL Dataframe中，并对其应用模式？
浏览 2提问于2017-04-20得票数 6
3回答
我已经使用spark-thriftserver connection将表从PostgreSQL数据库导入到spark-sql中，现在我可以从直线上看到这些表。
有没有办法把这些表格转换成spark数据帧？
浏览 1提问于2016-09-25得票数 2
有没有办法将数据帧模式序列化为json，并在以后反序列化它？
用例很简单:我有一个json配置文件，其中包含我需要读取的数据帧的模式。我希望能够从现有模式(在dataframe中)创建默认配置，并且能够通过从json字符串中读取相关模式来生成稍后使用的相关模式。
浏览 1提问于2016-12-04得票数 30
回答已采纳
我正在尝试从数据资产的data部分读取多个文件。我目前正在制作json文件的原型并将其直接写入Asset Bundle文件夹中，该文件夹位于一个名为"CommonData.dataset“的文件夹下。在我的资产目录中，CommonData已正确设置为Data set。 虽然我在Contents.json的data部分列出了两个文件，但我只获得了一个json文件的数据，这一切都运行得很好，它被记录为一组条目： {
"data" : [
{
"filename" : "ATestFile.json",
浏览 22提问于2021-07-24得票数 0
回答已采纳
我使用的是spark，我想创建查询来连接数据库中的不同表。
Apache和connection已经在使用示例：
CREATE TEMPORARY VIEW jdbcTable
USING org.apache.spark.sql.jdbc
OPTIONS (
url "jdbc:mysql://XXX.XXX.XXX.XXX/mydatabase",
driver "com.mysql.cj.jdbc.Driver",
dbtable "mydatabase.mytable1",
user "XXXX",
pa
浏览 3提问于2022-03-24得票数 0
回答已采纳
当我试图在Spark-SQL外部数据源上做一些测试时，会发生这个问题。
我以两种方式构建数据帧，并比较收集操作的速度。而且我发现如果列数太大，从外部数据源构建的数据帧将会滞后。我想知道这是否是Spark-SQL的外部数据源的限制。:-)
为了更清楚地表达这个问题，我编写了一段代码：
在我的外部Datasource API基准代码中，它实现了一个假的外部数据源(实际上是一个RDD[String，ArrayInt] )，并通过以下方式获取数据帧
val cmpdf = sqlContext.load("com.redislabs.test.dataframeRP", Map[St
浏览 2提问于2016-01-09得票数 1
能列出列出Hibernate帧工作中使用的所有设计模式吗？
我知道一些设计模式，如DAO，ORM等。
如果可能的话，举几个例子。
浏览 4提问于2014-08-12得票数 3
1回答
我正在从s3存储桶中读取大量文件。 在读取这些文件之后，我想对数据帧执行过滤操作。 但在执行过滤操作时，会再次从s3存储桶下载数据。如何避免数据帧重新加载？ 在过滤操作之前，我已经尝试过缓存和/或持久化数据帧。但是，数据还是从s3存储桶中以某种方式再次被拉了出来。 var df = spark.read.json("path_to_s3_bucket/*.json")
df.persist(StorageLevel.MEMORY_AND_DISK_SER_2)
df = df.filter("filter condition").sort(col("
浏览 6提问于2019-09-05得票数 0
我正在尝试解析位于我的数据帧的一列中的json数据。
我想从该列中取消列出数据，并为json数据中每个键创建特定的列
浏览 0提问于2018-05-14得票数 0
2回答
我需要使用Spark在一列中保存一个Map(键-值对)。要求是其他人可以通过其他工具使用数据，如PIG，因此最好以通用格式保存Map，而不是使用特殊格式的字符串。我使用以下代码创建列：
StructField("cMap", DataTypes.createMapType(StringType, StringType), true) ::
然后，在我创建数据帧之后，我得到了模式：
|-- cMap: map (nullable = true)
| |-- key: string
| |-- value: string (valueContainsNull = tru
浏览 2提问于2017-05-28得票数 0
我正在尝试从亚马逊离子格式文件创建数据帧。但在spark中，我没有找到任何离子类型的格式。所以，我使用json格式来加载ion文件，但是它抛出了错误。有没有办法从ion文件中创建数据帧。
我试着用下面的代码
val df = spark.read .format("json") .load("file:/home/mohan/Downloads/test_journal.ion")
浏览 0提问于2019-12-27得票数 0
我希望从spark-sql CLI获得输出。但是数据在CSV中，用"\t“分隔。有没有办法使用纯sql来做到这一点？ cmd like：spark-sql -e 'select * from csv.`xxx` where xxx=xxx' 唯一的方法是先创建一个临时视图，然后再查询该视图？
浏览 33提问于2020-09-18得票数 1
我试图在pyspark中创建空的dataframe，在pyspark中，我从外部JSON文件传递scehma，但是Json不允许我指定struct类型，所以我提到它是string。json文件： "OptionalEvents" : {
"Event1":
"StructType([StructField('id',StringType(), True),StructField('time',StringType(), True),StructField('ts',StringTyp
浏览 39提问于2021-08-23得票数 1
回答已采纳
我已经在created的全球环境中创建了大约500个数据帧，并且我在csv文件中列出了所有这些数据帧的名称。我要去拿那个号码。每个数据帧的观测结果。我知道我需要使用nrow(dataset_name)命令，但是有什么方法可以创建一个循环，这样R就可以从csv读取数据集名称并执行nrow命令吗？
p.s.-我是R的新手，如果这个问题很基本，请原谅我。蒂娅！
你好，布罗克
浏览 4提问于2016-04-19得票数 0
回答已采纳
我将使用spark-sql cli替换hive cli shell，并使用以下命令运行spark-sql cli (我们在yarn Hadoop集群上使用的是已经复制到/conf的hive-site.xml )
.> spark-sql然后外壳被打开并且工作正常，
然后我执行类似这样的查询，
./spark-sql>select devicetype，count(*) from mytable group by devicetype；
命令执行成功，结果正确。但我注意到性能非常慢。
从spark作业ui 中，我注意到只有一个执行器被标记为已使用，所以这可能就是原因。
我尝试修改sp
浏览 5提问于2015-01-22得票数 2
假设我们将一个表作为文本文件存储在Hive中。我们在这个表中有两列: id & groupid。 hdfs存储路径如下所示：(groupid也是分区列) ../groupid=1/1
../groupid=2/2
../groupid=3/3
... 每个文本文件(1，2，3...)存储ids列表。 例如，文件1的内容为： 123
2358
3456
... 是否可以将此表作为数据帧读取？ 结果dataframe应该是 groupid | id
1 | 123
1 | 2358
1 | 3456
2 | ...
2 | .
浏览 25提问于2019-02-19得票数 0
1回答
我有一个代码，它试图与多个数据帧进行左连接，因为从每个数据帧构建的属性将定位在我试图编写的最终json文件中的不同位置。此外，代码将随着新元素的添加而增长。使用目前的方法，代码几乎需要3-4个小时，最后由于性能问题而中止。解决此性能问题的更好方法是什么？Lkp_df1 lkd_df2 etc Main_df =main_df.join(按键，‘left’) .select( ....)是我在代码中使用的模式
浏览 1提问于2020-09-18得票数 0
我不希望在从一组jsons创建数据帧时推断出inferSchema = 'false'模式，但我不能像从csv中读取时那样传递。下面是我读取数据的方式：
df = spark.read.json(r's3://mypath/')
浏览 5提问于2017-12-12得票数 4
回答已采纳
在哪种场景下，我们应该更倾向于使用spark RDD来编写解决方案，在哪种场景下，我们应该选择使用spark-sql。我知道spark-sql提供了更好的性能，它对结构和半结构数据的处理效果最好。但是，在选择spark Rdd和spark-sql时，我们还需要考虑哪些因素。
浏览 1提问于2020-05-29得票数 0
我们是否可以使用Spark-SQL或scala检查spark数据帧中的每一列是否都包含特定的字符串(例如"Y")？
我已经尝试了以下方法，但我认为它不能正常工作。
df.select(df.col("*")).filter("'*' =='Y'")
谢谢，Sai
浏览 0提问于2017-09-09得票数 2
回答已采纳
1回答
我有一些代码可以将嵌套的json dict放到dataframe中。这并不是很有效，而且我想知道在创建数据帧之前是否需要使用numpy数组进行存储。字典大小为100万，item为JSON字符串。
ALL=dict()
ALL[0]= """{id1: 'Big_JSON' }"""
for k_id, dd in ALL.items() :
ii+=1
if ii > -1 :
dfi= pd.io.json.json_normalize(dd)
if ii == 0 :
浏览 0提问于2017-03-05得票数 0
我正在尝试构建一个应用程序，它将使用原始套接字从用户空间发送802.11个管理帧和数据帧。我能够使用sendto()函数发送数据帧，但我也需要发送管理框架，因为我大部分时间都被困在那里。有什么可行的办法吗？
浏览 2提问于2018-01-15得票数 2
我正在尝试创建一个简单的函数，可以用来将json数据存储到文件中。我现在有这样的代码
def data_store(key_id, key_info):
try:
with open('data.txt', 'a') as f:
data = json.load(f)
data[key_id] = key_info
json.dump(data, f)
pass
except Exception:
print("Erro
浏览 1提问于2016-04-22得票数 1
回答已采纳
背景
我有一个数据帧，看起来像这样：
------------------------------------------------------------------------
|name |meals |
------------------------------------------------------------------------
|Tom |{"breakfast": "banana", "lunch
浏览 34提问于2019-10-25得票数 0
回答已采纳
2回答
我是scala的新手，正在尝试从元素数组中创建自定义模式，以基于新的自定义模式读取文件。 我从json文件中读取数组，并使用explode方法，为列数组中的每个元素创建了一个数据帧。 val otherPeople = sqlContext.read.option("multiline", "true").json(otherPeopleDataset)
val column_values = otherPeople.withColumn("columns", explode($"columns")).select("c
浏览 14提问于2020-05-02得票数 0
回答已采纳
我试图用jsonlite::fromJSON解析json，然后各种疯狂的东西又回来了。This question展示了一个例子，我在一个文件(blarg.json)中给出了json，并检查了返回值。重复执行以下操作： blarg.json文件： [{ "id": 211,
"sub_question_skus": { "0": 329, "behavior": 216 } },
{ "id": 333,
"sub_question_skus": [ 340, 341 ]
浏览 31提问于2020-04-01得票数 0
回答已采纳
我需要做到以下几点，而且由于我在星火方面缺乏经验，我很难找到一种方法来实现这个目标：
从存储在S3. 中的.json.gz文件读取数据。
每个文件包含Google数据的一部分，其中包含中指定的模式。
文件名在模式ga_sessions_20170101_Part000000000000_TX.json.gz中，其中20170101是YYYYMMDD日期规范，000000000000是一个增量计数器，当一天中有多个文件时(通常是这样)。
因此，一整天的数据是由多个文件组成的，这些文件具有增量的“部件编号”。
一般每天有3到5个文件。
JSON文件中的所有字段都使用qoute
浏览 3提问于2018-03-06得票数 3
回答已采纳
2回答
如果我在查询中使用spark-sql，然后使用不正确的命名空间/数据库引用CTE，则查询工作正常(意外)。当我在生产中运行查询时(在Databricks上)，我会得到一个表或视图未找到错误(预期)。
意外的传递行为可以通过spark-sql在本地复制。
WITH myview AS (
SELECT 1 AS column
)
SELECT
*
FROM
invalid_namespace.myview;
当我期望它失败时，它会返回"1“。
有人能帮我使它在本地失败吗?这样我们就可以在部署之前进行适当的测试了吗？
从终端复制的确切步骤：
$ spark-sql
...
s
浏览 1提问于2020-07-15得票数 1
回答已采纳
3回答
我有几个.csv文件，每个文件对应一个每月的客户列表和一些关于他们的信息。每个文件都包含相同的客户信息，例如：
names(data.jan)
ID AGE CITY GENDER
names(data.feb)
ID AGE CITY GENDER
为了简化，我将只考虑两个月，1月和2月，但我真正的csv文件集是从1月到11月：
考虑到“客户X"，我有三种可能的情况：
1-客户X在一月份的数据库中列出，但他离开了，现在没有在二月份列出。2-客户X同时在一月份和二月份的数据库中列出。3-客户X在二月份进入数据库，因此他不会在
浏览 2提问于2013-12-04得票数 3
我在从Json文件中读取项目时遇到了一些问题，并且在将数据从Json文件中提取到列时也遇到了一些问题。 {
"sample":[
{
"value":"Red",
"id":"1"
},
{
"value":"green",
"id":"2"
},
{
"value":"o
浏览 3提问于2021-09-16得票数 0
回答已采纳
1回答
我有一个SQL数据库，我想在其中选择JSONfiles的一列并将其转换为可读的R数据帧。我成功地从我的数据库创建了JSONfiles的数据帧，但是当我尝试使用fromJSON函数读取它们时，它并没有读取所有的JSONfiles。
JSON列是每一行都有一个data$products_json文件的列。
rs = dbSendQuery(mydb, "SELECT products_json FROM orders")
data = fetch(rs, n=-1)
library(rjson)
jfile <- fromJSON(data$products_json)
浏览 7提问于2019-07-05得票数 0
回答已采纳
我已经丢弃了一个扩展基于this answer的json编码器的数据帧字典。我只是改变了转储数据帧的方式，出于我自己的目的，将表的“记录”改为orient=的“表”。 不知何故，我无法从json读取数据帧；准确地说，pandas似乎可以正确读取它(没有引发异常)，但它充满了NaN值。 有没有人可以检查我是否做错了什么，或者这是不是熊猫的bug (可能指的是多索引数据帧)？ 我使用的是pandas版本1.1.4。 下面的代码足以(我希望)测试pandas是否在我的机器上是KO的，或者我是否以某种方式弄乱了数据帧的格式。我还尝试用一个包括两个索引的虚拟数据帧来重现它，并且没有遇到问题。 还要注意
浏览 13提问于2020-12-03得票数 0
回答已采纳
我正在尝试将JSON文件读取到pandas数据帧中(更具体地说，最终目标是将JSON转换为CSV) 因此，我有一个JSON格式： ["[{\\"key1\\":\\"value1\\",\\"key2\\":\\"value2\\"}]"] 如果我使用下面这行代码，结果数据帧就会在一个大的blob中出现： df = df.read_json(json_filename) 我注意到，如果我手动进入JSON文件并删除所有\\，那么当我将其读取到数据帧中时，它会正常工作。但我感觉我没有使用正确的语法；Pandas我确
浏览 11提问于2021-06-24得票数 1
回答已采纳
我有一个数据帧，模式如下： root
|-- Id: integer (nullable = true)
|-- Id_FK: integer (nullable = true)
|-- Foo: integer (nullable = true)
|-- Bar: string (nullable = true)
|-- XPTO: string (nullable = true) 根据该数据帧，我希望创建一个JSON文件，其列名和类型如下 {
"Id": "integer",
"Id_FK": "integer"
浏览 12提问于2019-09-03得票数 0
回答已采纳
我有一个非常大的json文件，它以多个对象的形式存在，对于小型数据集来说，这是可行的。
data=pd.read_json(file,lines=True)
但是在相同但更大的数据集中，它会在8gb的ram计算机上崩溃，所以我尝试将其转换为先列出下面的代码
data[]
with open(file) as file:
for i in file:
d = json.loads(i)
data.append(d)'
然后将列表转换为
df = pd.DataFrame(data)
这确实可以将其转换为一个列表，即使是大数据集文件也是如此，但是当我
浏览 4提问于2022-11-14得票数 0
2回答
我使用system()函数从R中触发Python脚本，python脚本将一个数据帧写入一个.csv文件中，然后需要导入到R中，我想知道是否可以将数据帧从Python直接返回到R。
R
command = "python"
path2script='"/Desktop/testing_connection.py"'
allArgs = path2script
output = system2(command, args = allArgs, stdout=TRUE)
Python
df_temp = pd.read_csv('/Deskto
浏览 6提问于2016-08-19得票数 3
回答已采纳
我使用spark-sql进行数据迁移项目。那么我应该如何在spark中实现stage area呢？何时使用spark sql缓存或持久化？有没有实时用例？
~Sha
浏览 0提问于2018-10-12得票数 0
2回答
当我们创建spark数据帧时，我们将数据帧中的数据发送到Kudu和Kafka(依次被提取并进入S3)
然而，一旦数据帧被插入，我们在Kudu中看到的精度是1e-15
现在，如果我使用相同的数据帧并将其转换为Kafka可以使用的格式
override def getKafkaDataFrame(df: DataFrame) : DataFrame = {
df.withColumn("key", to_json(struct(df.col(PK1),
df.col(PK2)))
.withColumn("value", to_json(struct(
浏览 51提问于2020-02-07得票数 0
我有一个Mongo change流(一个pymongo应用程序)，它不断地获取集合中的更改。这些由程序接收的更改文档将发送到Azure事件中心。Spark notebook必须在文档进入Event Hub时读取文档，并与该集合的spark表进行模式匹配(将文档中的字段与spark表列进行匹配)。如果文档中的字段少于表中的字段，则必须使用Null添加列。
我正在从Event Hub读取事件，如下所示。
spark.readStream.format("eventhubs").option(**config).load().
正如文档中所说，原始消息位于我要转换为字符串的数据帧的“
浏览 1提问于2019-01-12得票数 0
我在谷歌存储桶里有一些数据。它是Json格式的，起源于Kafka。我想在存储桶的顶部用spark-sql创建一个临时视图。
我试着这样做
CREATE TEMPORARY VIEW TEMP_1 USING org.apache.spark.sql.json OPTIONS ( path "gs://xxx/xx/");
现在，当我试图描述视图名称时，它只给我一个有限的长度，并且没有显示所有的列名。
keys struct<eventIDs:array<string>,id:string> NULL
values struct<Col
浏览 13提问于2021-02-24得票数 0
2回答
假设我的工作目录中有一组T1、T2...TN类型的.JSON文件，每种类型都有不同数量的文件。每个.JSON文件都是一个数据帧列表。
阅读这些内容很简单：
library(jsonlite)
T1_l <- lapply(list.files(pattern = "T1"), fromJSON, flatten = TRUE)
T2_l <- lapply(list.files(pattern = "T2"), fromJSON, flatten = TRUE)
.
.
.
TN_l <- lapply(list.files(pattern =
浏览 20提问于2017-08-31得票数 0
回答已采纳
1回答
我有一个大的json文件，大小超过2GB。由于数据大小非常大，所以我无法创建具有整个数据集的数据帧。我希望解析特定的信息并写入CSV文件。
因此，我正在寻找一些技术来创建具有特定行数的数据帧。
假设我在将json解析为数据帧时有200万行，我想要创建一个数据帧，每个进程只有10k-15k行。然后把一些信息写到CSV文件中。
每个进程将有10k-15k行，直到它完成所有200万行。
我正在使用tidyjson和dplyr包。
浏览 2提问于2017-06-23得票数 0
我有两个从XML数据创建的数据帧；它们有每个文件的文件名和路径的列表，包括一些额外的元数据。像这样的东西 filename - filepath - meta1 - meta2 - meta3 基本上，每个数据帧中的文件可能在另一个数据帧中具有相同的文件名，但它们将位于不同的路径中。我正在尝试比较这两个数据帧，以找出哪些文件在这两个数据帧中是唯一的，以及哪些文件名在这两个数据帧中是通用的。我将只查看文件名；因此，如果一个文件存在于两个数据帧上，即使路径不同，我也会将它们视为重复。 在指定我只想使用filename列之后，我开始研究各种Pandas方法，并找到了适用于我的示例的drop_dup
浏览 28提问于2020-11-09得票数 0
1回答
JSON字符问题
、、
我使用RMongo库从mongo数据库中提取了一些数据。我一直在处理这些数据，没有任何问题。但是，我需要访问一个最初以JSON格式保存在数据库中的字段。因为rmongodb将数据保存为数据帧，所以我现在有一个长度为1的大字符向量：
res1 = "[ { \"text\" : \"@Kayture Beyoncé jam session ?\" , \"name\" : \"beponcé \xed\xa0\xbc\xed\xbc\xbb\" , \"screenName\" : \"Colaaaa
浏览 19提问于2017-02-28得票数 0
回答已采纳
我基本上有一个过程，在这个过程中，我对一个API进行多次调用，并在JSON返回中使用一个令牌，将这个包传递到函数顶部，再次调用API以获得一个“分页”文件。
总之，我必须调用和下载共计758 In的88个JSON文件。JSON文件都是以相同的方式格式化的，并且具有相同的“模式”，或者至少应该这样做。在将每个JSON文件下载到数据帧后，我尝试读取它，然后尝试将该数据文件合并到主数据帧中，因此基本上，我将有一个大数据帧与所有88个JSON文件一起读取。
但是，我遇到的问题大概是在66号文件上，系统(Python/Databricks/Spark)决定更改字段的文件类型。它始终是一个string，然
浏览 5提问于2022-06-24得票数 0
我已经创建了很多数据帧作为预处理的一部分。由于我限制了6 6GB的内存，我想从内存中删除所有不必要的数据帧，以避免在scikit-learn中运行GRIDSEARCHCV时耗尽内存。
1)是否有一个函数可以只列出当前加载到内存中的所有数据帧？
我尝试了dir()，但它提供了许多数据帧以外的其他对象。
2)我创建了一个要删除的数据帧列表
del_df=[Gender_dummies,
capsule_trans,
col,
concat_df_list,
coup_CAPSULE_dummies]
范围(&R)
for i in del_df:
del (i)
但它不会删
浏览 1提问于2015-08-27得票数 52
1回答
我有一段pyspark代码，用于将数据帧转换为物理表：
df.write.mode('overwrite).saveAsTable('sometablename')
如果数据帧df包含名称中包含空格的列，则会失败，并显示以下错误：
18/03/08 10:33:29 ERROR CreateDataSourceTableAsSelectCommand: Failed to write to table pivot_up_spaces_Export_Data_4
org.apache.spark.sql.AnalysisException: Attribute name
浏览 4提问于2018-03-08得票数 1
1回答
如何列出模式之间包含字符的数据帧
、、、、
如何列出名称中包含字母之间的模式的文件？假设我们有几个数据帧，如AgI_M.txt、AgI_PQ.txt、AgII_M.txt、AgII_PQ.txt、AgIII_M.txt、AgIII_PQ.txt、AgN_M.txt、AgN_PQ.txt、CoI_M.txt、CoI_PQ.txt、CoN_M.txt、CoN_PQ.txt……我们想列出一个以"Ag“开头，以"_M.txt”结尾的列表。我需要知道我们在模式定义中间放了什么。到现在为止，我猜它应该是这样的 Ag_files<-list.files(path="",
浏览 12提问于2019-12-19得票数 0
回答已采纳
我是Apache Spark的新手，有时还在苦苦挣扎。我正在尝试导入一个相当复杂的json文件，并在将其保存到parquet文件之前将其展平。
我的json文件是一个商店树。
{
"id": "store02",
"name": "store name",
"domain": "domain",
"currency": "EUR",
"address1": "Somewhere",
"country": "GER
浏览 0提问于2018-02-12得票数 3
我写了两个小程序：
第一个将数据从.txt文件导入到熊猫数据框架中，操作数据并将最终数据导出到json文件中。
第二个代码将json文件中的数据导入数据帧。
不幸的是，当从json文件导入数据时，列的顺序发生了变化。我在网上看到了几个示例，其中使用OrderedDict在新表中创建固定结构，但如何将OrderedDict应用于现有表？
我尝试过几个版本，包括下面的版本，但没有一个版本有效：
df = OrderedDict(pd.DataFrame.from_dict(json_data, orient='columns'))
和
data = OrderedD
浏览 0提问于2018-12-24得票数 7
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
