AMQPFIND

A 'find' compatible script for subscribing to AMQP messages from the SSEC Data Center.

Living manual is a Google Doc linked here.

Datacenter documentation is here.

Usage:

amqpfind -h hwing -u himawari -p guest -X himawari -k himawari8.delta \
   |xargs -n1 -P8 myconverter.sh 

AMQPSEND

Takes in JSON with a list: [[topic1, {content1}], [topic2, {content2}]] and sends them to a server.

Optionally can daemonize to background (with idle timeout) and forward content to the background process, in order to keep connection open for a longer duration.

Simple example:

cat <<EOF |python3 amqpfind/amqpsend.py -u 'user' -p 'password' -H amqpesrver.example.com -X testexchange
[["testing.one.two.three", {"foobar": "bazquux"}], ["testing.one.two.three", {"nom": "inal"}]]                                                  
EOF