All Questions
700
questions
-1
votes
0
answers
18
views
how to redirect absl logs in a pybinded C++ from the calling Python module [closed]
I have a Python binary that leverages numerous C++ functions through pybind11.
Both in Python and C++ I'm using absl logging.
I am trying to setup absl in Python to wrote logs to file instead of ...
- 509
0
votes
0
answers
19
views
stream is hunging when no internet is detected instead of closing the pipeline
I'm trying to display save and stream rgb/ir data to an external server via network, but i want to also be able to display and save in case there is no network so that i don't lose data.
iam using ...
0
votes
0
answers
47
views
How can I work with FastAPI websocket endpoint and rabbitmq streams (basic_consume)
I am trying to stream data from my device to a rabbitmq server and then consume it on my backend and websocket it to the front-end. This is my code:
@router.websocket("/ws/messages")
async ...
0
votes
1
answer
211
views
How does streaming work in OpenAI's APIs?
I have a basic understanding of how event streams work. I am currently converting langchain code to directly use OpenAI's API and I have a piece of code I am a bit confused about.
def stream_message(
...
- 23
0
votes
0
answers
21
views
Pythonic parallelized streaming of batches (list-of-dicts) of JSON into a single file write
I have a multiprocessing thread pool where each job returns a requested batch of JSON (an array of objects). I want all results to write into a single file, but without storing the full result (as a ...
- 889
0
votes
0
answers
24
views
Redis Streams - Is XADD MAXLEN supposed to update 'max-deleted-entry-id' similar to XTRIM and XDEL?
I had a question regarding the MAXLEN parameter of XADD when dealing with Redis Streams. During my testing I found that using the XDEL commands and using the XTRIM with a MAXLEN parameter commands ...
0
votes
1
answer
34
views
How do I perform an atomic XREAD and XDEL on a Redis Stream?
I am trying to design a system on Redis, where:
There is a queue of messages
There is a single writer to the queue
There are multiple consumers of "messages" in the queue, each continuously ...
- 4,199
0
votes
0
answers
178
views
m3u playlist vlc streaming issue, and python script shows not working
so I recently stuck in a issue. I am working on an iptv project the streams are yet not public. we have 4 different systems. but when we test udp links on each of system all system didnt get any ...
0
votes
1
answer
31
views
Slowly Updating Side Inputs & Session Windows - Transform node AppliedPTransform was not replaced as expected
In my apache beam streaming pipeline, I have an unbounded pub/sub source which I use with session windows.
There is some bounded configuration data which I need to pass into some of the DoFns of the ...
- 376
0
votes
0
answers
46
views
Video Playback is not working in my gstreamer python3 command
I'm currently trying to stream,and save to file with the code below using gstreamer in python3 , the gstreamer piplines work fine in the terminal but when i use them in the python code i can ...
1
vote
1
answer
36
views
create and update group row sums on pandas dataframe
i have a dataframe with students and their school subjects:
Subject
Mark
Helen
Art
20
Philosophy
16.8
Economics
12
Colin
Maths
19.2
Geography
17
History
15
For every subject, there is a ...
- 39
0
votes
1
answer
90
views
How can i monitor changes in variables python
I have two files that i input as pandas DFs in my code, where the first one has different product categories and the products in stock:
Name
Stock
ART
Paintings
20
Ceramics
10
BOOKS
Poetry
50
...
- 39
2
votes
2
answers
53
views
Video stream source change using Python Flask and JS
I have the following server side route code for stream
movies_list = ['./mov1.mp4', './mov2.mp4', './mov3.mp4',]
@app.route("/video", methods=["GET"])
def video():
headers = ...
- 21
0
votes
0
answers
46
views
Python - OpenCV Videocapture stuck
I have a esp32cam with a stream on a webserver. When I try to open the stream with opencv it gets stuck
import cv2
from PIL import Image, ImageTk
raw_stream = cv2.VideoCapture()
raw_stream.open("...
1
vote
2
answers
117
views
How to start a download and render a response without hitting disk?
So I have a scientific data Excel file validation form in django that works well. It works iteratively. Users can upload files as they accumulate new data that they add to their study. The ...
- 1,037