我从Kafka那里得到了JSON格式的数据，并在PySpark中以DataFrame的形式读取了这些数据。在我从Kafka获得数据后，它显示为DataFrame格式： DataFrame[value: string] 但是，该值包含JSON / DICT格式。testing.writeStream.foreach(print_row).start() R
浏览 24提问于2020-01-13得票数 0
1回答
在获得动态对象并使用以下代码将其转换为Json之后：人们发现，转换的Json格式(以下格式1)不是我所需要的格式： "data": [{ ["
浏览 3提问于2018-07-16得票数 1
回答已采纳
2回答
我想知道如何将pyspark dataframe转换为json格式。name ㅣ type 'kane' ㅣ 'message'->2, 'text'->3 数据帧到json格式 data{name : 'james&
浏览 12提问于2020-08-14得票数 0
我在DataFrame上应用了groupby，之后它将DataFrame转换为pandas.core.groupby.groupby.DataFrameGroupBy格式。如何将pandas.core.groupby.groupby.DataFrameGroupBy转换为常规DataFrame，或者如何从pandas.core.groupby.groupby.DataFrameGroupBy数据类型访问单个列？
浏览 7提问于2018-10-27得票数 1
我有一个示例数据帧，其中的数据如下：2020-09-05 10:19:112020-11-11 10:49:32我想将其转换为json，但数据格式更改为：我使用以下代码将其转换为json：
df.to_json('output
浏览 26提问于2021-06-03得票数 1
回答已采纳
1回答
我想知道如何将数据帧转换为json格式。ㅣ count'kane' ㅣ 'text' ㅣ 3'kane' ㅣ 'message'ㅣ 3 数据帧到json格式 data = [
浏览 9提问于2020-08-14得票数 1
回答已采纳
1回答
列DataFrame中的JSON
、、、、
我正在尝试制作一个大容量插入的dataframe，我在Postgres中的表有一个字段类型 JSON ，我想在它上插入原始JSON，但是当我试图实现它时，python从双引号改为单引号'，在技术上它破坏了DataFrame中的JSON列，我只想找到一种方法来实现这个批量插入。首先以json格式获取数据，然后为数据操作和清理制作一个Dataframe，最后我想在Postgr
浏览 8提问于2021-02-17得票数 0
4回答
我正在从云服务器读取JSON格式的API数据，如下所示如何编写代码将此数据帧存储到任何数据库中的数据帧中。如何将JSON格式转换为DataFrame？
需求输出格式如表所示
浏览 42提问于2020-02-17得票数 0
具有从不同源聚合的多个日期时间列的dataframe格式不一致。如何正确地将所有日期时间列转换为iso格式？
目前，我最好的解决方案是使用date_format='iso'将数据格式转换为json。json_string = my_dataframe.to_json(orient='records', date_format
浏览 2提问于2020-06-09得票数 1
2回答
我正在使用星星之火/scala，我有一个dataframe。有年份/月/日列，值为ex。2020/9/2.如何在转换为datetime (Yyyy)的同一数据中添加一列？我找到了如何将日期从字符串格式转换为日期格式的方法，但我无法找到如何组合值并将其转换为日期时间的解决方案。谢谢你的建议或暗示
浏览 7提问于2022-05-24得票数 0
回答已采纳
我有一个dataframe，它有一个列，其中一个对象数据类型的格式为mm:ss。我希望将该列转换为时间格式，以便可以将时间转换为秒，而不是mm:ss。但是，我无法将该列转换为时间格式。我的数据示例： time24:5626:57 我试过了： df['time'] = pd.to_timedelta(df['time'
浏览 21提问于2019-09-29得票数 1
回答已采纳
TLDR：我从一个dask包创建了一个dataframe。dask dataframe将每个观察(事件)作为一列对待。因此，我没有为每个事件设置行数据，而是为每个事件设置了一列。其目标是将列转换为行，就像熊猫可以使用df.T转换数据格式一样。
Details：我有。为了达到我的起点，下面是将json从磁盘读入dask.bag并将其转换为dask.dataframe
浏览 7提问于2016-08-04得票数 4
回答已采纳
我希望这样做，它从MongoDB读取数据(也可以使用其他DB )，然后将输出转储到DB，然后可以从我们的系统中选择输出。我已经研究了几天，发现了以下几点：
将输出转换为所需的格式(json/csv)我还没有弄清楚如何将数据从DB导入到IndexedDataSet。此外，我还读过关于RD
浏览 5提问于2016-05-05得票数 0
回答已采纳
如何将数据( json )转换为pandas Dataframe，以便可以在grafana简单json中将“key”作为列，将“value”作为行动态填充到表中。实际上，它不是一个完美的数组格式，我如何操作它来作为数据帧工作？我们将非常感谢您的帮助。data = {"name":"john","class":"fifth"}
{"n
浏览 1提问于2018-12-06得票数 1
1回答
在的基础上，如何将数据格式的所有列都写到一个卡夫卡主题中。目前我有一个带有一些列的dataframe，我应该用一个键将它写到kafka，因此我从旧的一个创建了一个新的dataframe，并指定了键和值： .option("kafka.bootstrap.servers", "test:8808&qu
浏览 0提问于2019-08-13得票数 1
回答已采纳
在我的csv文件中，"ESTABLİSHMENT DATE"列由如下所示的斜杠分隔：01/22/2012。我正在将csv格式转换为JSON格式，这需要用熊猫来完成，但是"ESTABLİSHMENT DATE"列没有正确地转换为JSON。df = pd.read_csv(my_csv)
df.to_json("some_path", orient="
浏览 5提问于2020-12-17得票数 2
回答已采纳
1回答
我将读取一个csv文件并发送到json流格式。import json
sample = {"event_id": "dd
浏览 1提问于2021-12-03得票数 0
我是通过从RDD中的文本文件加载数据来创建PySpark的。现在，我想将这个RDD转换成一个dataframe，但是我不知道RDD中有多少列和列。现在，由于我不知道列是什么，所以如何将rdd转换为dataframe？注释1:我不知道列的原因是因为我试图创建一个通用脚本，该脚本可以从从任意数量的列读取的任何文件中创建数据格式。注释2: --我知道还有一个名为toDF
浏览 9提问于2017-04-07得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
