小编 yo*_*nus的帖子

如何从databricks中的增量文件中删除数据?

我想从 databricks 中的增量文件中删除数据。我使用这些命令
例如:

PR=spark.read.format('delta').options(header=True).load('/mnt/landing/Base_Tables/EventHistory/')
PR.write.format("delta").mode('overwrite').saveAsTable('PR')
spark.sql('delete from PR where PR_Number=4600')
Run Code Online (Sandbox Code Playgroud)

这是从表中删除数据,但不是从实际的增量文件中删除数据。我想删除文件中的数据而不使用合并操作,因为连接条件不匹配。谁能帮我解决这个问题。

谢谢

sql apache-spark-sql pyspark azure-databricks delta-lake

4
推荐指数
1
解决办法
2万
查看次数

werkzeug.exceptions.BadRequestKeyError: 400 Bad Request: 浏览器(或代理)发送了一个该服务器无法理解的请求。密钥错误:'id'

html页面

{%block title%}Login page{% endblock %}

{%block content%}
<form action = '#' method="post">
   <p>creds:</p>
   <p><input type="number"  placeholder="id"  Id="id" /></p>
   <p><input type="text"  placeholder="nm"  name="nm" /></p>
   <p><input type="submit" value="submit" /></p>
</form>
{%endblock%}
Run Code Online (Sandbox Code Playgroud)

应用代码

@app.route("/")
def home():
    return render_template("login.html")

@app.route("/",methods = ["POST","GET"])
def post():
    if request.method == "POST":
        user = request.form['nm']
        id = request.form['id']
        sql = ('''INSERT INTO abc
                (id, name) VALUES (?, ?)
                ''')
        val = (id,user)
        cur.execute (sql, val)
    return 'Ok'
Run Code Online (Sandbox Code Playgroud)

我尝试使用 return.form.get('id') 但它返回 null

任何人都可以帮我解决这个问题吗

谢谢

api rest post flask

3
推荐指数
2
解决办法
2万
查看次数