这个问题在这里已经有答案了:
如何从pyspark的sqllitedb文件加载表(2个答案)
将sqlite文件加载到Dataframe中(2个答案)
上个月关门了。
我有一个扩展名为.sqlite3的文件(test.sqlite3),如何从spark或python读取它
尝试了以下内容,但无法正确读取模式
import sqlite3
import pandas as pd
from pyspark.sql import SparkSession
spark = SparkSession \
.builder \
.appName("read sqlite3 file") \
.getOrCreate()
df = spark.read.csv('/Downloads/test.sqlite3')
df.printSchema()
df.show(5)
暂无答案!
目前还没有任何答案,快来回答吧!