akka-quickstart-scala

KO | EN

gitlite — search

#javascript #hacktoberfest #react #typescript #machine-learning #deep-learning #linux #macos #windows #awesome #awesome-list #security #pytorch #open-source

akka-quickstart-scala

(★ 9)

Implementing InternetOfThings-IoT and Akka-quartz-scheduler

akka-quickstart-scala 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# Implementation akka-quartz-scheduler and Internet of things #
This is a multimodule project it include two modules that can live separated but I want to give you the idea 
of allways work in a multimodules environments.
* [akka-quartz-scheduler](https://github.com/enragedginger/akka-quartz-scheduler): We needed something similar to the linux cron service, execute several tasks spread in time, change the schedule of those tasks, change the tasks and all of this without stop the services.
* Full implementation of [the akka example of InternetOf Things](https://doc.akka.io/docs/akka/current/guide/tutorial_1.html)

## Implementation of akka-quartz-scheduler in a cron service problem ##

What is my problem?: I have several tasks that need to execute following an specific schedule and **with different parameters every time that be executed**. There are not periodical tasks but I know that for example every sunday or every week someone will publish when I have to execute our tasks. In our example we are going to inspect an url about films and tv series *http://mejorenvo.com/*. So we can review a fixed amount of page or schedule inspect page those days that we know that company is planning to add new film pages.

### What will you find in the Implementation of akka-quartz-scheduler ? ###

* How implement tasks that can be execute like in *a linux cron services* but without the security problems and at the same time with a variable schedule without stoped any process. I have implement 2 scheduler:
  - Internal configuration: In *application.conf* akka configuration file.
  - External configuration: In an external file, this file won't be in our compiled distribution. So while our daemons are working I can change this external configuration and the jobs will be rescheduled without any problem and without stop my akka application.

### What you will not find here, but you should ###

* A proper ErrorHandler implementation. 
* Implementation of Supervisor strategy.
* Test module: This point we'll be interesting in the future. All code have been prepared for be tested in akka environment without mocking any value.

### Requirements, Installation, Launching ###

#### Requirements ####

* jdk 1.7+ -> how check java version: java -version
* scala 2.11.x -> how check scala version: scala -version
* sbt 0.13.11+ -> how check sbt version: sbt about

#### Installation and Launching ####

* clone repository
* go to root project
* type in your terminal:
    - **sbt "AkkaSchedulerPoc/runMain com.ldg.BootNotScheduled 1 5"** . Description: It will let you review from page 1 to page 5 and then ends all process:
        ```
        .....
        2019-04-08 11:41:49.435[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-2] DEBUG akka.event.EventStream - Default Loggers started
        2019-04-08 11:41:49.468[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - Start process in Akka Scheduler Example
        2019-04-08 11:41:51.404[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-2] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p1.html
        2019-04-08 11:41:51.430[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p3.html
        2019-04-08 11:41:51.459[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-6] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p4.html
        2019-04-08 11:41:51.974[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p5.html
        2019-04-08 11:41:51.976[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - An operation have done. applicationInDevelopment moviePageTitle:Películas y Series en versión original moviePageUrl:http://mejorenvo.com/p2.html
        2019-04-08 11:41:51.980[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IOTask - Start IOTask process
        2019-04-08 11:41:51.980[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-7] INFO  com.ldg.actors.IOTask - Stop IOTask process
        2019-04-08 11:41:51.992[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] INFO  com.ldg.actors.IoTAdmin - Stop process in Akka Schedule Example
        [DEBUG] [04/08/2019 11:41:51.997] [IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-3] [EventStream] shutting down: StandardOutLogger started
        2019-04-08 11:41:51.997[IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-4] DEBUG akka.event.EventStream - shutting down: StandardOutLogger started
        [DEBUG] [04/08/2019 11:41:51.999] [IotAdmin_Not_Scheduled-akka.actor.default-dispatcher-3] [EventStream] all default loggers stopped
        [success] Total time: 4 s, completed 08-abr-2019 11:41:52

```        
    - **sbt "AkkaSchedulerPoc/runMain com.ldg.BootScheduled"** . Description: You have to configurate the pages to review and when it must be done. Every thing in an external configuration file (root/akka-quickstart-scala/scriptsdb/cronmoviepages.conf)

## Implementation of akka example of Internet of Things ##

This project implement [the akka example of InternetOf Things](https://doc.akka.io/docs/akka/current/guide/tutorial_1.html)
The idea is that **each house can has several sensors devices** and should be possible get/set values in each device. Each house must have a **Network Connection Component (NCC)** It must allow connect the sensor device to Internet.

![myimage-alt-tag](https://github.com/ldipotetjob/akka-quickstart-scala/blob/master/images/IoTImage.jpg)
*Copyright of My Children (Mariela and Samuel)*

akka-quickstart-scala

akka-quickstart-scala 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

akka-quickstart-scala

akka-quickstart-scala 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README