小编Har*_*vey的帖子

运行python kafka生产者时“self.async”上的SyntaxError

$ docker run 34a24a8a745e
Traceback (most recent call last):
  File "//producer.py", line 1, in <module>
    from kafka.producer import KafkaProducer
  File "/usr/local/lib/python3.9/site-packages/kafka/__init__.py", line 23, in <module>
    from kafka.producer import KafkaProducer
  File "/usr/local/lib/python3.9/site-packages/kafka/producer/__init__.py", line 4, in <module>
    from .simple import SimpleProducer
  File "/usr/local/lib/python3.9/site-packages/kafka/producer/simple.py", line 54
    return '<SimpleProducer batch=%s>' % self.async
                                              ^
SyntaxError: invalid syntax

Run Code Online (Sandbox Code Playgroud)

我曾看到过一个相同的早期错误,但我正在使用 from kafka import KafkaProducer

我的新 python 脚本使用from kafka.producer import KafkaProducer但我仍然收到 self.async 错误

python python-3.x kafka-python

3
推荐指数
1
解决办法
1612
查看次数

如何使用 Python 更新现有 Azure blob 的内容

我正在寻找更新/覆盖一个简单的天蓝色 blob 的内容,该 blob 包含一个 txt 文件,其中包含简单的日期字符串。我用它来存储某个进程的最后运行时间。

我尝试了几种方法,但没能找到任何对我的事业有帮助的文档。任何帮助或建议表示赞赏。

import datetime
from azure.storage.blob import BlobServiceClient, BlobClient

maxdate = datetime.datetime.now()
now = maxdate.strftime("%m-%d-%YT%H:%M:%S")

def upload_to_blob(data):

  conn_str = "<conn_str>"
  blob_service_client = BlobServiceClient.from_connection_string(conn_str)

  blob_client = blob_service_client.get_blob_client(container="vstscontainerreleases", blob="last_run.txt")

  blob_client.upload_blob(data)

upload_to_blob(now)
Run Code Online (Sandbox Code Playgroud)

我已经尝试了上述简单的重新上传相同的 blob,但收到一条错误消息,指出 blob 已存在。

Time:2021-08-18T11:53:00.0692411Z
ErrorCode:BlobAlreadyExists
Error:None
Run Code Online (Sandbox Code Playgroud)

python azure azure-blob-storage

3
推荐指数
1
解决办法
3460
查看次数

Dockerfile 构建错误:系统找不到指定的路径

C:\kafka> docker build Dockerfile
[+] Building 0.0s (1/2)
 => ERROR [internal] load build definition from Dockerfile                                                                                               0.0s
 => => transferring dockerfile: 63B                                                                                                                      0.0s
------
 > [internal] load build definition from Dockerfile:
------
failed to solve with frontend dockerfile.v0: failed to read dockerfile: error from sender: walk Dockerfile: The system cannot find the path specified.

Run Code Online (Sandbox Code Playgroud)

以上是我遇到的错误和命令运行的示例。我的 Dockerfile 被命名为“Dockerfile”,因为我已经阅读了许多答案,但仍然没有解决。我的 Dockerfile 也在我所在的目录中。

docker dockerfile

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