小编Ban*_*ras的帖子

我正在制作 Flask 应用程序。我写了这段代码：

from flask import Flask, session
from flask_caching import Cache

app = Flask(__name__)
cache = Cache(app, config={'CACHE_TYPE': 'simple'})

@app.route('/my-route')
@cache.cached(timeout=50)
def my_route():
  id = request.args.get('id')
  schema = Schema({
    Required('id'): All(Coerce(str))
})
try:
    schema({'id': id})
except MultipleInvalid as e:
    str(e)

  ans=test(session[‘id’])
  return ans

if __name__ == '__main__':
    app.run(debug=True)

当我运行 append access 时localhost:8000/my-route?id=aDj1948，我得到：

RuntimeError: The session is unavailable because no secret key was set. Set the secret_key on the application to something unique and secret. 错误。

我重写了@cache.cached(timeout=50, …

我有下面的代码将数据添加到弹性搜索中

from elasticsearch import Elasticsearch
es = Elasticsearch()
es.cluster.health()
r = [{'Name': 'Dr. Christopher DeSimone', 'Specialised and Location': 'Health'},
 {'Name': 'Dr. Tajwar Aamir (Aamir)', 'Specialised and Location': 'Health'},
 {'Name': 'Dr. Bernard M. Aaron', 'Specialised and Location': 'Health'}]
es.indices.create(index='my-index_1', ignore=400)

for e in enumerate(r):
    #es.indices.update(index="my-index_1", body=e[1])
    es.index(index="my-index_1", body=e[1])

#Retrieve the data
es.search(index = 'my-index_1')['hits']['hits']

要求 如何更新文档

r = [{'Name': 'Dr. Messi', 'Specialised and Location': 'Health'},
     {'Name': 'Dr. Christiano', 'Specialised and Location': 'Health'},
     {'Name': 'Dr. Bernard M. Aaron', 'Specialised and Location': 'Health'}] …

我正在使用 Ms-Access，并创建了一个用户表单，其中有许多文本框。这些盒子被命名为：Box1、Box2、Box3 ...

我需要遍历所有盒子，但我不知道哪一个是最后一个。为了避免循环遍历所有用户窗体控件，我想尝试以下操作：

For i =1 To 20

If Me.Controls("Box" & i).value = MyCondition Then
    'do stuff
End If

Next i

此错误出现在 Box6 处，这是第一个未找到的框。有没有办法捕获此错误并在发生时退出循环。

我知道我可以使用On Error，但我宁愿用代码捕获这个特定的实例。

谢谢，乔治

在另一个类似的问题中，他们暗示“安装较旧的 Spark 2.4.5”。

编辑：上面链接中的解决方案显示“安装 Spark 2.4.5 并且它确实有 kafkautils”。但问题是我无法下载spark2.4.5 - 即使在存档中也不可用。

我听从了建议，安装了旧版本的 Spark - Spark2.4.6（唯一可用的旧版本），并且还有 python37、kafka-python、pyspark 库。

我有我的spark_job.py 文件需要使用kafka

from pyspark.streaming.kafka import KafkaUtils

当点击“python Spark_job.py”时

ModuleNotFoundError: No module named 'pyspark.streaming.kafka'

错误仍然存​​在！

Spark_job.py：

from __future__ import print_function
import sys
import os
import shutil

from pyspark import SparkContext, SparkConf
from pyspark.streaming import StreamingContext
from pyspark.sql import Row, SparkSession
from pyspark.streaming.kafka import KafkaUtils # this is the problem
import json


outputPath = 'C:/Users/Admin/Desktop/kafka_project/checkpoint_01'


def getSparkSessionInstance(sparkConf):
    if ('sparkSessionSingletonInstance' not in globals()):
        globals()['sparkSessionSingletonInstance'] = …

我正在设置一个脚本，我需要使用 package.json 中的一些函数fast-ai。事实是，我在 Windows 上，当我定义路径时，fast-ainamed 中的函数load_learner无法加载模型。

我试图将函数更改为包：

state = pickle.load(open(str(path) + '/' + str(fname), 'rb'))

代替：

state = pickle.load(open(path/fname, 'rb'))

但我收到此错误：

 File "lib\site-packages\fastai\basic_train.py", line 462, in load_learner
    state = pickle.load(open(path/fname, 'rb'))
  File "\lib\pathlib.py", line 1006, in __new__
    % (cls.__name__,))
NotImplementedError: cannot instantiate 'PosixPath' on your system

我的路径定义为：

folder_path = './models/model1'
fname = 'model.pkl'

我把这个函数称为： model = load_learner(folder_path, fname)

如何在此功能中使用 Windows 路径？

更新 1

发布的答案仅在 Linux 上是正确的。我在 Windows 上仍然有这个问题。我没有找到在 Windows 上通过 PosixPath 的方法。我发现的唯一解决方案是从我的模块中更改内部包，但这不是解决此类问题的安全方法。

提前致谢。