duyet

-- show running queries (pre 9.2)
SELECT procpid, age(clock_timestamp(), query_start), usename, current_query 
FROM pg_stat_activity 
WHERE current_query != '<IDLE>' AND current_query NOT ILIKE '%pg_stat_activity%' 
ORDER BY query_start desc;

-- show running queries (9.2)
SELECT pid, age(clock_timestamp(), query_start), usename, query 
FROM pg_stat_activity 
WHERE query != '<IDLE>' AND query NOT ILIKE '%pg_stat_activity%' 

duyet

let resp = await fetch('http://wttr.in')
if (resp.ok) {
  console.log(await resp.text())
}

duyet

.

duyet

from datetime import datetime

from airflow.models import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator

DAG_OWNER = 'lvduyet@fossil.com'
DAG_ID = 'dag_name'
SCHEDULE_INTERVAL = '@weekly'

duyet

import logging
import socket

log = logging.getLogger('udp_server')


def udp_server(host='127.0.0.1', port=1234):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

duyet

import os
import unittest

from airflow.models import DagBag

class TestDags(unittest.TestCase):
    """
    Generic tests that all DAGs in the repository should be able to pass.
    """

duyet

https://drive.google.com/drive/folders/1ImgU5xnmgETI8QNr3KnwZHo0-UZk-QmR?usp=sharing

duyet

https://drive.google.com/file/d/1PekrksBFHP3Ju3kum_qc-aHA9Fk5Ma5a/view?usp=sharing

duyet

https://drive.google.com/file/d/0B9Z_a3MtkjyAV1MyZGp4Nk8yWkZYYXZQend5T1N5YktId2xB/view?usp=drivesdk

duyet

https://drive.google.com/open?id=1qZgW0DZXIF7lEibK91QYrx4U1L6I3NHD