如何在Python中从WebSocket解析JSON数据到变量

huangapple
go评论138阅读模式
英文:

How to parse JSON data from websocket to variable in Python

问题

我使用AGI Asterisk进行语音识别。它通过WebSocket连接并接收JSON响应。
脚本收集单词并将它们粘合成短语。
到目前为止，一切都正常。

我需要进一步使用收集到的短语（发送到Telegram，然后通过API发送到帮助台系统），但如果我只使用text作为变量，它不起作用。
如何将text设置为变量？

  1. #!/usr/bin/python3
  2. from asterisk.agi import *
  3. import os
  4. from websocket import create_connection
  5. import json
  6. import traceback
  7. import requests
  9. AUDIO_FD = 3
  10. CONTENT_TYPE = 'audio/l16; rate=8000; channels=1'
  11. ACCEPT = 'audio/pcm'
  13. def telegram_bot_sendtext(text):
  14.     bot_token = '6069wxts_nWcA'
  15.     bot_chatID = '-10300'
  16.     bot_message = text
  17.     send_text = 'https://api.telegram.org/bot' + bot_token + '/sendMessage?chat_id=' + bot_chatID + '&reply_to_message_id=2&parse_mode=Markdown&text=' + bot_message
  18.     response = requests.get(send_text)
  19.     return response.json()
  21. def process_chunk(agi, ws, buf):
  22.     agi.verbose("Processing chunk")
  23.     ws.send_binary(buf)
  24.     res = json.loads(ws.recv())
  25.     agi.verbose("Result: " + str(res))
  26.     if 'result' in res:
  27.         text = " ".join([w['word'] for w in res['result']])
  28.         os.system("espeak -w /tmp/response22.wav \"" + text.encode('utf-8') + "\"")
  29.         os.system("sox /tmp/response22.wav -r 8000 /tmp/response.wav")
  30.         agi.stream_file("/tmp/response")
  31.         os.remove("/tmp/response.wav")
  33. def startAGI():
  34.     agi = AGI()
  35.     agi.verbose("EAGI script started...")
  36.     ani = agi.env['agi_callerid']
  37.     did = agi.env['agi_extension']
  38.     agi.verbose("Call answered from: %s to %s" % (ani, did))
  39.     ws = create_connection("ws://localhost:2700")
  40.     ws.send('{ "config" : { "sample_rate" : 8000 } }')
  41.     agi.verbose("Connection created")
  42.     try:
  43.         while True:
  44.             data = os.read(AUDIO_FD, 8000)
  45.             if not data:
  46.                 break
  47.             process_chunk(agi, ws, data)
  48.     except Exception as err:
  49.         agi.verbose(''.join(traceback.format_exception(type(err), err, err.__traceback__)).replace('\n', ' '))
  50.     try:
  51.         telegram_bot_sendtext(text)
  52.     except Exception as exc:
  53.         print("Post_Auth_Script_Telega : Error : ", str(exc))
  54.     finally:
  55.         ws.close()
  57. startAGI()

JSON看起来像这样

Result: {
'result': [
{'conf': 1.0, 'end': 2.07, 'start': 1.71, 'word': 'One'},
{'conf': 1.0, 'end': 2.34, 'start': 2.07, 'word': 'Two'},
],
'text': 'One Two'}

  2. <details>
  3. <summary>英文:</summary>
  4. I am using agi asterisk for speech recognition. It connects via websocket and receives a response in json.
  5. The script collects words and glues them into a phrase.
  6. Everything is working at this stage.
  7. I need to use the collected phrase further (send to telegram and then via api to the helpdesk system), but it doesn&#39;t work if i just use **text** as a variable.
  8. How to make ***text*** a variable?
  9. #!/usr/bin/python3
  10. from asterisk.agi import *
  11. import os
  12. from websocket import create_connection
  13. import json
  14. import traceback
  15. import requests
  16. AUDIO_FD = 3
  17. CONTENT_TYPE = &#39;audio/l16; rate=8000; channels=1&#39;
  18. ACCEPT = &#39;audio/pcm&#39;
  19. def telegram_bot_sendtext(text):
  20. bot_token = &#39;6069wxts_nWcA&#39;
  21. bot_chatID = &#39;-10300&#39;
  22. bot_message = text
  23. send_text = &#39;https://api.telegram.org/bot&#39; + bot_token + &#39;/sendMessage?chat_id=&#39; + bot_chatID + &#39;&amp;reply_to_message_id=2&amp;parse_mode=Markdown&amp;text=&#39; + bot_message
  24. response = requests.get(send_text)
  25. return response.json()
  26. def process_chunk(agi, ws, buf):
  27. agi.verbose(&quot;Processing chunk&quot;)
  28. ws.send_binary(buf)
  29. res = json.loads(ws.recv())
  30. agi.verbose(&quot;Result: &quot; + str(res))
  31. if &#39;result&#39; in res:
  32. **text = &quot; &quot;.join([w[&#39;word&#39;] for w in res[&#39;result&#39;]])**
  33. os.system(&quot;espeak -w /tmp/response22.wav \&quot;&quot; + text.encode(&#39;utf-8&#39;) + &quot;\&quot;&quot;)
  34. os.system(&quot;sox /tmp/response22.wav -r 8000 /tmp/response.wav&quot;)
  35. agi.stream_file(&quot;/tmp/response&quot;)
  36. os.remove(&quot;/tmp/response.wav&quot;)
  37. def startAGI():
  38. agi = AGI()
  39. agi.verbose(&quot;EAGI script started...&quot;)
  40. ani = agi.env[&#39;agi_callerid&#39;]
  41. did = agi.env[&#39;agi_extension&#39;]
  42. agi.verbose(&quot;Call answered from: %s to %s&quot; % (ani, did))
  43. ws = create_connection(&quot;ws://localhost:2700&quot;)
  44. ws.send(&#39;{ &quot;config&quot; : { &quot;sample_rate&quot; : 8000 } }&#39;)
  45. agi.verbose(&quot;Connection created&quot;)
  46. try:
  47. while True:
  48. data = os.read(AUDIO_FD, 8000)
  49. if not data:
  50. break
  51. process_chunk(agi, ws, data)
  52. except Exception as err:
  53. agi.verbose(&#39;&#39;.join(traceback.format_exception(type(err), err, err.__traceback__)).replace(&#39;\n&#39;, &#39; &#39;))
  54. try:
  55. telegram_bot_sendtext(text)
  56. except Exception as exc:
  57. print(&quot;Post_Auth_Script_Telega : Error : &quot;, str(exc))
  58. finally:
  59. ws.close()
  60. startAGI()
  61. json looks like
  62. Result: {
  63. &#39;result&#39;: [
  64. {&#39;conf&#39;: 1.0, &#39;end&#39;: 2.07, &#39;start&#39;: 1.71, &#39;word&#39;: &#39;One&#39;}, 
  65. {&#39;conf&#39;: 1.0, &#39;end&#39;: 2.34, &#39;start&#39;: 2.07, &#39;word&#39;: &#39;Two&#39;}, 
  66. ], 
  67. &#39;text&#39;: &#39;One Two&#39;}
  68. </details>
  69. # 答案1
  70. **得分**: 0
  71. 以下是代码的翻译部分：
  72. ```python
  73. #!/usr/bin/python3
  74. from asterisk.agi import *
  75. import os
  76. from websocket import create_connection
  77. import json
  78. import traceback
  79. import requests
  80. AUDIO_FD = 3
  81. CONTENT_TYPE = 'audio/l16; rate=8000; channels=1'
  82. ACCEPT = 'audio/pcm'
  83. def telegram_bot_sendtext(text):
  84. bot_token = '606922aNwxts_nWcA'
  85. bot_chatID = '-100100'
  86. bot_message = text 
  87. send_text = 'https://api.telegram.org/bot' + bot_token + '/sendMessage?chat_id=' + bot_chatID + '&amp;reply_to_message_id=2&amp;parse_mode=Markdown&amp;text=' + bot_message
  88. response = requests.get(send_text)
  89. return response.json()
  90. def process_chunk(agi, ws, buf):
  91. agi.verbose("Processing chunk")
  92. ws.send_binary(buf)
  93. res = json.loads(ws.recv())
  94. agi.verbose("Result: " + str(res))
  95. if 'result' in res:
  96. text = " ".join([w['word'] for w in res['result']])
  97. try:
  98. telegram_bot_sendtext(text)
  99. except Exception as exc:
  100. print("Error: ", str(exc))
  101. os.system("espeak -w /tmp/response22.wav \"" + text.encode('utf-8') + "\"")
  102. os.system("sox /tmp/response22.wav -r 8000 /tmp/response.wav")
  103. agi.stream_file("/tmp/response")
  104. os.remove("/tmp/response.wav")
  105. def startAGI():
  106. agi = AGI()
  107. agi.verbose("EAGI script started...")
  108. ani = agi.env['agi_callerid']
  109. did = agi.env['agi_extension']
  110. agi.verbose("Call answered from: %s to %s" % (ani, did))
  111. ws = create_connection("ws://localhost:2700")
  112. ws.send('{ "config" : { "sample_rate" : 8000 } }')
  113. agi.verbose("Connection created")
  114. try:
  115. while True:
  116. data = os.read(AUDIO_FD, 8000)
  117. if not data:
  118. break
  119. process_chunk(agi, ws, data)
  120. except Exception as err:
  121. agi.verbose(' '.join(traceback.format_exception(type(err), err, err.__traceback__)).replace('\n', ' '))
  122. #    try:
  123. #        telegram_bot_sendtext(text)
  124. #    except Exception as exc:
  125. #        print("Error: ", str(exc))
  126. finally:
  127. ws.close()
  128. startAGI()

希望这对你有所帮助。如果你需要进一步的信息或翻译，请告诉我。

英文:

Final working verison

  1. #!/usr/bin/python3
  2. from asterisk.agi import *
  3. import os
  4. from websocket import create_connection
  5. import json
  6. import traceback
  7. import requests
  8. AUDIO_FD = 3
  9. CONTENT_TYPE = &#39;audio/l16; rate=8000; channels=1&#39;
  10. ACCEPT = &#39;audio/pcm&#39;
  11. def telegram_bot_sendtext(text):
  12. bot_token = &#39;606922aNwxts_nWcA&#39;
  13. bot_chatID = &#39;-100100&#39;
  14. bot_message = text 
  15. send_text = &#39;https://api.telegram.org/bot&#39; + bot_token + &#39;/sendMessage?chat_id=&#39; + bot_chatID + &#39;&amp;reply_to_message_id=2&amp;parse_mode=Markdown&amp;text=&#39; + bot_message
  16. response = requests.get(send_text)
  17. return response.json()
  18. def process_chunk(agi, ws, buf):
  19. agi.verbose(&quot;Processing chunk&quot;)
  20. ws.send_binary(buf)
  21. res = json.loads(ws.recv())
  22. agi.verbose(&quot;Result: &quot; + str(res))
  23. if &#39;result&#39; in res:
  24. text = &quot; &quot;.join([w[&#39;word&#39;] for w in res[&#39;result&#39;]])
  25. try:
  26. telegram_bot_sendtext(text)
  27. except Exception as exc:
  28. print(&quot;rror : &quot;, str(exc))
  29. os.system(&quot;espeak -w /tmp/response22.wav \&quot;&quot; + text.encode(&#39;utf-8&#39;) + &quot;\&quot;&quot;)
  30. os.system(&quot;sox /tmp/response22.wav -r 8000 /tmp/response.wav&quot;)
  31. agi.stream_file(&quot;/tmp/response&quot;)
  32. os.remove(&quot;/tmp/response.wav&quot;)
  33. def startAGI():
  34. agi = AGI()
  35. agi.verbose(&quot;EAGI script started...&quot;)
  36. ani = agi.env[&#39;agi_callerid&#39;]
  37. did = agi.env[&#39;agi_extension&#39;]
  38. agi.verbose(&quot;Call answered from: %s to %s&quot; % (ani, did))
  39. ws = create_connection(&quot;ws://localhost:2700&quot;)
  40. ws.send(&#39;{ &quot;config&quot; : { &quot;sample_rate&quot; : 8000 } }&#39;)
  41. agi.verbose(&quot;Connection created&quot;)
  42. try:
  43. while True:
  44. data = os.read(AUDIO_FD, 8000)
  45. if not data:
  46. break
  47. process_chunk(agi, ws, data)
  48. except Exception as err:
  49. agi.verbose(&#39;&#39;.join(traceback.format_exception(type(err), err, err.__traceback__)).replace(&#39;\n&#39;, &#39; &#39;))
  50. #    try:
  51. #        telegram_bot_sendtext(text)
  52. #    except Exception as exc:
  53. #        print(&quot;rror : &quot;, str(exc))
  54. finally:
  55. ws.close()
  56. startAGI()

huangapple
  • 本文由 发表于 2023年7月27日 20:38:19
  • 转载请务必保留本文链接：https://go.coder-hub.com/76779811.html
  • join
  • python-3.x
  • variables
  • websocket
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定