zmq ml template

100%

zmq ml template

✓ Published0🌍 Public

Last edited Apr 12, 2018

Created on Apr 12, 2018

A ZeroMQ REP socket on TCP port 5566 receives raw image frames as memory buffers, converts them to NumPy arrays, and feeds them through a preloaded Keras model for inference. The model processes each frame, clips the output to valid pixel ranges, concatenates an alpha channel, and sends the result back over the same socket. It logs inference and send times, calculates theoretical FPS, and handles errors by replying with an empty message.

AI-generated description

Similar vizzes

Loading thumbnail…

Simplified zeromq PUSH/PULL example

This example demonstrates a simple ZeroMQ PUSH/PULL message-passing pattern, where one process continuously generates random workloads and another receives and prints them. The pushventilator.py script uses `zmq.Context` and a PUSH socket to connect to a PULL socket bound on port 5558 by the pullsink.py process, sending random integers between 1 and 100 via `sink.send()`. The pullsink.py process uses `receiver.recv()` in a loop to display each received value, showing a real-time unidirectional data flow without any acknowledgment or synchronization beyond the initial connection.

Aalper

53% match

Loading thumbnail…

Gist ae31ce5b693d662b3add4af2919cea65

This example shows a Unity application that captures frames from a camera, sends them to a remote machine-learning API, and displays the stylized result in a UI Image component. It uses MiniJSON to serialize the image as base64-encoded PNG data into a JSON payload for a POST request to a RunwayML-style endpoint. The script repeatedly captures the camera’s RenderTexture at a set interval, uploads it, and updates a Preview sprite with the returned stylized image. It demonstrates real-time image processing through an external model with a simple polling loop to keep the remote service active.

Aandybak

50% match

Loading thumbnail…

Gist 919ad4cfb5475f2aa4b68109e6c02bc9

This example shows a Python script that configures and controls the LED Everloop on a MATRIX device. It first connects to the device’s data update port to count the available LEDs using `io_pb2.LedValue`, then sends a driver configuration with a fixed purple color to the base port via a ZeroMQ (ZMQ) PUSH socket. Using `zmq` and the `matrix_io` protocol buffers, it also pings a keep-alive port and registers an error callback. The script runs these tasks as separate processes with `multiprocessing`.

KKaitoKid

47% match

Loading thumbnail…

Gist 98636bb57280e38492740cdbe9c4901c

This example demonstrates a deep learning workflow for classifying brain images using TensorFlow and Keras. It loads CSV data from the braindr dataset, displaying a pandas DataFrame with vote counts, rater identities, and mean ratings for each image. The code builds a convolutional neural network with layers like Conv2D, MaxPooling2D, Dropout, and LeakyReLU, using Keras' Sequential API. It configures the model for GPU execution, imports optimizers such as RMSprop and Adam, and prepares callbacks like ModelCheckpoint for training.

Aakeshavan

45% match

Loading thumbnail…

Gist 919bd3761b3b882347732f6d4b85bbad

This example demonstrates a pipeline for predicting brain data quality using deep learning models, applied to 2D slices extracted from a 3D neuroimaging file. It shows how a URL to a `.nii.gz` file is sent to an OpenFaaS serverless function, which generates and returns image slices that are then processed for display. The code uses Python libraries including Matplotlib, PIL, NumPy, and Requests, converting base64-encoded slices into grayscale images and visualizing them side by side. The visualization highlights the workflow of fetching remote brain imaging data and rendering its 2D projections for quality inspection.

Aakeshavan

45% match

Loading thumbnail…

read remote image files in tensorflow // url file reader

This example demonstrates how TensorFlow can load remote image files directly from URLs by using a threaded queue to parallelize the fetching process. The code defines a `url_example_producer` function that leverages `tf.py_func` with `io.imread` from scikit-image to read images without blocking the global interpreter lock. A `tf.RandomShuffleQueue` with 64 enqueue threads feeds a batch dequeue operation, while a `tf.train.Coordinator` manages thread lifecycle and measures loading time for 1,000 identical image URLs.

Aaman-tiwari

44% match

Loading thumbnail…

Gist 5c36e7318dd5c85aa743

This visualization displays a 16-slice mosaic of brain MRI scans across three orthogonal planes (x, y, z), with yellow contour lines outlining anatomical labels from a segmentation. The code loads NIfTI brain images and masks via nibabel, masks background data with NumPy masked arrays, and uses nipy’s `plot_anat` and `contour_map` to render slices with matplotlib subplots. It computes bounding boxes from the affine transformation to select meaningful cut coordinates, then arranges the slices in 4×4 grids per plane. The function supports optional contouring and saving each mosaic as a PNG image.

Aakeshavan

44% match

Loading thumbnail…

Gist ef01d3ebfb3e6f5704bd

This example demonstrates a minimal WebSocket server implemented in Python, showing how to establish a handshake and exchange framed messages. It uses `SocketServer.StreamRequestHandler` for the network layer, manually performs the WebSocket handshake via `sha1` and `b64encode` against the defined magic string, and parses incoming frames by XOR-masking payload bytes. The code handles payload lengths up to 64-bit values and sends text frames with a 129 opcode. It prints received messages to the console, illustrating the core protocol mechanics without any visualization or data rendering.

Aahmohamed

43% match