【文件属性】:
文件名称:delta-rest:通过RESTful API与Delta Lake交互
文件大小:13KB
文件格式:ZIP
更新时间:2021-02-08 01:36:09
Python
三角洲休息
通过RESTful API与Delta Lake进行交互。
(非常欢迎提供帮助和请求请求!)
用法
安装
pip install deltarest
运行烧瓶服务
该服务必须在Spark驱动程序中运行(客户端部署模式下的spark-submit )。
from deltarest import DeltaRESTService
from pyspark . sql import SparkSession
SparkSession \
. builder \
. appName ( "local_test" ) \
. master ( "local" ) \
. config ( "spark.jars.packages" , "io.delta:delta-core_2.12:0.8.0" ) \
. getOrCreate ()
【文件预览】:
delta-rest-main
----.github()
--------workflows()
----requirements.txt(32B)
----LICENSE(11KB)
----test()
--------test.py(3KB)
--------__init__.py(0B)
----setup.py(317B)
----README.md(2KB)
----deltarest()
--------rest.py(9KB)
--------__init__.py(42B)
--------service.py(2KB)
----.gitignore(2KB)