asyncio & MQTT | adafruit | Page 1

sage crown Sep 19, 2023, 6:06 PM

#

It has to be something with MQTT - this code works. I poll AIO every 30 seconds for the last value and then updates and scrolls the message. So at least I have a backup plan for my project. 🙂

#

📎 async-timing.py

noble ruin Sep 19, 2023, 6:50 PM

#

had some IRL things, and since I have the ye olde schoole M4 MatrixPortal, switched over the code to ESP32SPI, waiting for song change 😉

sage crown Sep 19, 2023, 6:58 PM

#

oh, I can push changes, too

#

sorry I missed this

noble ruin Sep 19, 2023, 7:00 PM

#

can you change song again? I had to reload

sage crown Sep 19, 2023, 7:02 PM

#

done, had to take the dog out of course

noble ruin Sep 19, 2023, 7:04 PM

#

had to fix the payload_data vs. json_data, reloaded

sage crown Sep 19, 2023, 7:04 PM

#

updated

noble ruin Sep 19, 2023, 7:05 PM

#

I gotta get my own feed, this is gonna get redonk

sage crown Sep 19, 2023, 7:05 PM

#

sorry :/

noble ruin Sep 19, 2023, 7:06 PM

#

not your fault, I just hate to keep bugging you everytime I have a syntax error o_O I'm stumped by this one, and don't want to be

sage crown Sep 19, 2023, 7:06 PM

#

I don't mind, I'm the one getting help. 🙂

#

Though if you want, I could give you a 30 second audio sample or two and use this: https://github.com/prcutler/songmatrix/blob/main/identify.py

noble ruin Sep 19, 2023, 7:16 PM

#

if this keeps going, I'll figure out something... any frequently-changing MQTT feed ought to do

#

can you change song again?

sage crown Sep 19, 2023, 7:18 PM

#

yup, I wish I it would notifiy me in a thread

noble ruin Sep 19, 2023, 7:38 PM

#

I'm trying to publish from another async def to feed myself data 😉

sage crown Sep 19, 2023, 7:38 PM

#

gotcha

flint ravine Sep 19, 2023, 7:54 PM

#

I've missed a bit of this, but you're having issues with MQTT?

Does your MQTT-based code call the loop() method?

MQTT has keepalive messages that the client has to send the broker periodically (default varies by client but generally a few seconds) or the broker will close the connection.

The loop() method makes sure that they're sent often enough.

So any sleeping or other delays that don't give the loop() method a chance to run will cause the connection to get closed.

#

Sorry if this is ground you've already covered or not relevant to the issue you're seeing

sage crown Sep 19, 2023, 7:54 PM

#

No, appreciate the insight, thanks!

noble ruin Sep 19, 2023, 8:02 PM

#

how often does .loop() have to be called?

flint ravine Sep 19, 2023, 8:03 PM

#

it depends on the keepalive time that the client uses

#

but generally, often 🙂

noble ruin Sep 19, 2023, 8:03 PM

#

the connection isn't dying,, it some other weird interplay between async and mqtt

flint ravine Sep 19, 2023, 8:04 PM

#

if you're trying to receive data, .loop() handles that as well

noble ruin Sep 19, 2023, 8:04 PM

#

a variable assignment isn't sticking

#

well, I have a simplified version working, not sure what's different except I'm creating my own feed data... publishing then callback to message()

#

I did increase the interval and used force

#

let me see if I can narrow down the differences

sage crown Sep 19, 2023, 8:15 PM

#

awesome, thank you

noble ruin Sep 19, 2023, 9:40 PM

#

i broke something, always times out now (not sure if socket_timeout works right on esp32spi)

sage crown Sep 19, 2023, 9:41 PM

#

no problem, appreciate all the help

noble ruin Sep 19, 2023, 9:51 PM

#

oh, wow, had accidentally copied an old lib with the cert problem

#

(after CIRCUITPY crashed and wiped itself)

sage crown Sep 19, 2023, 9:52 PM

#

doh

noble ruin Sep 19, 2023, 9:52 PM

#

OK, I'll post what I have... structure is a mess and it's ESP2SPI, but the async part is the key I think

sage crown Sep 19, 2023, 9:53 PM

#

awesome, thanks. I need to head upstairs to make dinner for the family, I'll take a look tonight.

noble ruin Sep 19, 2023, 9:54 PM

#

I'll repost if I clean it up more or get it more like what you have

📎 code.py

noble ruin Sep 19, 2023, 11:37 PM

#

some tweaking probably needed... the color changes don't sync exactly to a text update, and sometimes the update seems to jump a bunch of pixels

but maybe we can figure out the nuance of difference between the code files that makes it stop working

sage crown Sep 19, 2023, 11:38 PM

#

I'm struggling to put it back together - straight copy / paste works though! So now I know it's just me. 🙂

noble ruin Sep 19, 2023, 11:51 PM

#

I can't find why yours doesn't work, there's something subtle to it

#

I added a second line of text, but I'm still not doing JSON, can't imagine that would matter, but anything goes at this point

sage crown Sep 19, 2023, 11:53 PM

#

well, that's the weird thing. I have it working, except as soon as I put my message code in to parse and display the json, it shows Loading again, but then doesn't show the updated text, it's the old artist

#

I don't have to do JSON, that might be the next part is ripping that out and just sending a string and splitting it

sage crown Sep 20, 2023, 12:20 AM

#

It's the JSON - I passed the payload, made sure it was a string and split it, and it works!

#

And I very much like your exception handling, thank you for that and everything else

noble ruin Sep 20, 2023, 1:07 AM

#

glad you figured it out, I never would have guessed JSON vs. string could explain the behavior

sage crown Sep 20, 2023, 1:07 AM

#

if you hadn't done all that work I would have never guessed - thanks so much

noble ruin Sep 20, 2023, 1:08 AM

#

you’re welcome, i learned a lot too… maybe I’ll do an MQTT project now 🙂

noble ruin Sep 20, 2023, 5:11 AM

#

publishing and receiving JSON working OK, key pieces are in publish and message, still not sure what nuance of difference between what works and what doesn't

📎 code.py

#asyncio & MQTT