Azure函数blob触发器blob paratemer错误

Question

我使用blob触发器读取blob内容，作为pandas DF进行处理，并将blob附加到我使用的Azure SQL server。

blob触发器没有按预期工作，因此我将main函数中的所有代码都定义为：

def main(myblob: func.InputStream):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"
                 f"Blob Size: {myblob.length} bytes")
    file = re.sub(r'^(.*?)\/','',myblob.name)
    if file not in processedfiles:
        stream = BytesIO((myblob.read()))
        stream.seek(0)

但是，我得到了以下错误：

Exception: FunctionLoadError: cannot load the BlobFileTrigger function: 
binding myblob has invalid non-type annotation <sqlalchemy.sql.functions._FunctionGenerator object at 0x7faa340f6a00>

有人可以帮助我找到此问题的原因吗？

function.json的配置如下:

{
  "scriptFile": "__init__.py",
  "disabled": false,
  "bindings": [
      {
          "name": "myblob",
          "type": "blobTrigger",
          "direction": "in",
          "path": "input/{name}",
          "connection":"StorageConnection"
      }
  ]
}

Answer 1

>

配置的function.json文件很好。

如果您获取的是空字节字符串，请先使用查找（0）方法，然后使用Read（）fromstream。

确保if条件在Processedfile上是正确的，因为如果在Processedfile中没有找到任何文件，那么只有您的案例将执行。

（myblob.read ()))

参考：Python io的read（）和getvalue（）方法。字节IO

Python中使用Blobtrigger的Azure函数