lskk / earthquake-detector Goto Github PK

Collection of drafts, technical reports, working papers, in emergency & disaster management. Koleksi draft, laporan teknis, catatan & tulisan, di bidang manajemen kedaruratan & kebencanaan.

Home Page: http://lskk.org/

License: Creative Commons Attribution 4.0 International

Jupyter Notebook 2.19% HTML 56.73% C# 32.61% PowerShell 1.07% Arduino 7.38% Shell 0.02%

earthquake-detector's Introduction

emergency-work

Collection of drafts, technical reports, working papers, in emergency & disaster management. Koleksi draft, laporan teknis, catatan & tulisan, di bidang manajemen kedaruratan & kebencanaan. Edited 12/16/2016

earthquake-detector's People

Contributors

Stargazers

Watchers

Forkers

kevprakoso

earthquake-detector's Issues

Store stationary sensors signals from RabbitMQ to MongoDB

Use Python 3.6 (Anaconda)
Use pyspark
Use Spark Structured Streaming (preferred), or at least Spark Streaming (DStream)
RabbitMQ Spark Streaming Source, choices: (note: Spark Streaming docs say that custom receivers aren't supported for Python as of Spark 2.2, however https://github.com/radanalyticsio/streaming-amqp has a Python example, so there is hope)
MongoDB Spark Streaming Sink: https://docs.mongodb.com/spark-connector/master/scala/streaming/

Tambahkan lokasi sensor

geometry: GeoJSON Point

B200 Earthquake Detektor (sistem deteksi gempa)

Penjajakan penggunaan Arduino

Studi literatur/projek: Detecting Seismic Waves with Android and IOT, by Shuvro Pal

Link dari Pak @asetijadi : http://www.codeproject.com/Articles/1117162/Detecting-Seismic-Waves-with-Android-and-IOT

Mohon progress report hasil temuannya disampaikan di issue ini, dan disusun dalam dokumentasi http://semut.readthedocs.io ya

Tambahkan timestamp + time zone + Buffer/batch pengiriman data ke RabbitMQ

pointTime: Timestamp dalam format ISO 8601, dalam timezone UTC, contoh 2016-12-15T10:04:41Z
timeZone: Time zone, contoh Asia/Jakarta
Buffering: Input data 40 sample/detik. Pengiriman data 200 sampel dalam 5 detik, 1 message dalam 5 detik (idealnya configurable, misal per 1 detik, 2 detik, 10 detik, dsb.).

Contoh message:

{
    "pointTime": "2016-12-15T10:04:41Z",
    "timeZone": "Asia/Jakarta",
    "interval": 25,
    "geometry": {
	"type": "Point",
	"coordinates": [125.6, 10.1]
    },
    "accelerations": [
        {
            "x": -0.1243,
            "y": 14.6464725,
            "z": -12.5433
        }
    ]
}