Membuat Service Timer dengan Twisted

Servis dengan timer akan sangat membantu kita mengerjakan pekerjaan secara otomatis setiap waktu yang ditentukan. Twisted sangat membantu kita untuk membuat skrip untuk keperluan ini.

Kali ini kita akan mencoba membuat skrip yg melakukan 2 tugas yg dijalankan setiap beberapa waktu.

Persiapan

Pertama kita siapkan environment untuk kodingan kita.

# Buat virtualenv di folder `venv` menggunakan Python 3
$ virtualenv -ppython3 venv

# Gunakan Python environment nya
source venv/bin/activate

# Install twisted
pip install twisted[tls]
# Twisted HTTP Client
pip install treq

Servis Twisted Sederhana

timer-service.py

from twisted.application import service
from twisted.logger import Logger

# Main service
application = service.Application('My Timer App')
log = Logger()

Kira akan jalankan berkas skrip diatas dengan perintah twistd. Lihat link ini: Twisted Application untuk informasi lebih lanjut.

Jalankan dengan perintah berikut

# jalankan perintah `twistd --help` untuk menampilkan bantuan perintah
twistd -ny timer-service.py

Tugas 1: Tampilkan Waktu Terkini

Kita tulis sebuah fungsi yang akan menunjukkan waktu terkini. Fungsi ini akan dipanggil setiap 5 detik.

timer-service.py

# ... added after the code before
def get_current_time():
    log.info("Current time: {current_time}", current_time=time.asctime())


# Call every 5 seconds
timer_service_1 = TimerService(step=5, callable=get_current_time)
timer_service_1.setServiceParent(application)

Tugas 2: Tampilkan Alamat IP Saya

Tugas dengan timer kedua ini berfungsi untuk mendapatkan alamat IP kita dengan mengakses https://httpbin.org/ip menggunakan treq.

# ... tambahkan setelah kode sebelummnya
class GetMyIPService:

    @inlineCallbacks
    def show_my_ip(self, response):
        response = yield response.json()
        log.info("My IP: {response}", response=response['ip'])

    def call(self):
        d = treq.get('https://httpbin.org/ip')
        d.addCallback(self.show_my_ip)
        return d


get_ip_srv = GetMyIPService()
# Call every 15 seconds
timer_service_2 = TimerService(step=15, callable=get_ip_srv.call)
timer_service_2.setServiceParent(application)

Kode Lengkapnya

import time

import treq
from twisted.application import service
from twisted.application.internet import TimerService
from twisted.internet.defer import inlineCallbacks
from twisted.logger import Logger

# Main service
application = service.Application('My Timer App')
# Logger
log = Logger()


def get_current_time():
    log.info("Current time: {current_time}", current_time=time.asctime())


# Call every 5 seconds
timer_service_1 = TimerService(step=5, callable=get_current_time)
timer_service_1.setServiceParent(application)


class GetMyIPService:

    @inlineCallbacks
    def show_my_ip(self, response):
        response = yield response.json()
        log.info("My IP: {response}", response=response['ip'])

    def call(self):
        d = treq.get('https://httpbin.org/ip')
        d.addCallback(self.show_my_ip)
        return d


get_ip_srv = GetMyIPService()
# Call every 15 seconds
timer_service_2 = TimerService(step=15, callable=get_ip_srv.call)
timer_service_2.setServiceParent(application)

Jalankan Service

Jalankan service dengan perintah:

# run twistd --help to show usage of this command
twistd -ny timer-service.py

Contoh log setelah servis dijalankan

2023-09-19T00:51:51+0700 [-] Loading timer-service.py...
2023-09-19T00:51:51+0700 [-] Loaded.
2023-09-19T00:51:51+0700 [twisted.scripts._twistd_unix.UnixAppLogger#info] twistd 23.8.0 (/home/jockerz/jockerz.github.io/codes/venv/bin/python 3.11.2) starting up.
2023-09-19T00:51:51+0700 [twisted.scripts._twistd_unix.UnixAppLogger#info] reactor class: twisted.internet.epollreactor.EPollReactor.
2023-09-19T00:51:51+0700 [<unknown>#info] Current time: Tue Sep 19 00:51:51 2023
2023-09-19T00:51:51+0700 [twisted.web.client._HTTP11ClientFactory#info] Starting factory _HTTP11ClientFactory(<function HTTPConnectionPool._newConnection.<locals>.quiescentCallback at 0x7fbeef0d2d40>, <twisted.internet.endpoints._WrapperEndpoint object at 0x7fbeef0c7390>)
2023-09-19T00:51:52+0700 [<unknown>#info] My IP: 182.253.127.230
2023-09-19T00:51:56+0700 [<unknown>#info] Current time: Tue Sep 19 00:51:56 2023
2023-09-19T00:52:01+0700 [<unknown>#info] Current time: Tue Sep 19 00:52:01 2023
2023-09-19T00:52:06+0700 [<unknown>#info] Current time: Tue Sep 19 00:52:06 2023
2023-09-19T00:52:06+0700 [<unknown>#info] My IP: 182.253.127.230
2023-09-19T00:52:11+0700 [<unknown>#info] Current time: Tue Sep 19 00:52:11 2023

Jekyll