Я создал функцию запуска Azure Service Bus.Всякий раз, когда в теме служебной шины появляется сообщение, моя функция срабатывает.Входящие сообщения сжимаются с помощью API C # deflatestream.Я использую zlib в python для его распаковки, при этом я сталкиваюсь со следующей ошибкой:
ошибка -3 при распаковке данных: недопустимый тип блока
C # сжатие
using (FileStream compressedFileStream = File.Create(file.FullName +
COMPRESSED_FILE_EXTENSION))
{
using (DeflateStream compressionStream = new
DeflateStream(compressedFileStream, CompressionMode.Compress))
{
originalFileStream.CopyTo(compressionStream);
}
}
Python-код, который читает сообщение из моих метаданных триггера, mySbMsg - параметр сообщения триггера шины службы
with open(os.environ['mySbMsg'], 'rb') as topic_msg:
msg = topic_msg.read()
try:
decompressed_data = zlib.decompress(msg, -14)
except Exception as e:
print(e)
Также есть другой способ чтения сообщения, вместоos.environ [ 'mySbMsg'].