簡單小小script

網路上除了爬蟲外, 也不外乎有一堆殭屍, 每天都以打攪別人為樂
一直直看到一堆scanner在掃22以外的port
雖然放著也不會怎樣…
看久了心情就不太美麗…

好吧寫個script來維護一下世界和平

請服用….XD

#!/bin/bash
today=`date '+%m%d%y'`

ben_fail_ssh () {
grep 'Failed password' /var/log/auth.log | grep sshd | grep -o '[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}' | sort | uniq | awk '{print $1}' | while read IP
do
  if [ "$IP" != "127.0.0.1" ] && [ "$IP" != "122.116.33.14" ] && [ "$IP" != "118.163.31.241" ] ; then
    /sbin/iptables -A INPUT -s $IP -j DROP
  fi
done

/sbin/iptables-save >/root/rule/iptables_"$today".rule
}

backup_rule () {
/sbin/iptables-save >/root/rule/iptables_"$today".rule
/bin/sed -i '/fail2ban/d' /root/rule/iptables_"$today".rule
/bin/cp /root/rule/iptables_"$today".rule /etc/iptables.ipv4
}

reset_fw () {
echo "
*filter
:INPUT ACCEPT [650:121885]
:FORWARD ACCEPT [0:0]
:OUTPUT ACCEPT [688:83029]
:fail2ban-ssh - [0:0]
:fail2ban-ssh443 - [0:0]
-A INPUT -p tcp -m multiport --dports 443 -j fail2ban-ssh443
-A INPUT -p tcp -m multiport --dports 22 -j fail2ban-ssh
-A fail2ban-ssh -j RETURN
-A fail2ban-ssh443 -j RETURN
COMMIT" > default.rule
/sbin/iptables-restore < default.rule
rm default.rule
}

clean_rule () {
cat $1 | grep -o '[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}' | sort | uniq | awk '{print $1}' | while read IP
do
  if [ "$IP" != "127.0.0.1" ] && [ "$IP" != "122.116.33.14" ] && [ "$IP" != "118.163.31.241" ] ; then
    echo iptables -A INPUT -s $IP -j DROP
    /sbin/iptables -A INPUT -s $IP -j DROP
  fi
done
}

ben_fail_ssh
reset_fw
clean_rule /root/rule/iptables_"$today".rule
backup_rule

#!/bin/bash

today=`date '+%m%d%y'`

ben_fail_ssh () {

grep 'Failed password' /var/log/auth.log | grep sshd | grep -o '[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}' | sort | uniq | awk '{print $1}' | while read IP

if [ "$IP" != "127.0.0.1" ] && [ "$IP" != "122.116.33.14" ] && [ "$IP" != "118.163.31.241" ] ; then

/sbin/iptables -A INPUT -s $IP -j DROP

done

/sbin/iptables-save >/root/rule/iptables_"$today".rule

}

backup_rule () {

/sbin/iptables-save >/root/rule/iptables_"$today".rule

/bin/sed -i '/fail2ban/d' /root/rule/iptables_"$today".rule

/bin/cp /root/rule/iptables_"$today".rule /etc/iptables.ipv4

}

reset_fw () {

echo "

*filter

:INPUT ACCEPT [650:121885]

:FORWARD ACCEPT [0:0]

:OUTPUT ACCEPT [688:83029]

:fail2ban-ssh - [0:0]

:fail2ban-ssh443 - [0:0]

-A INPUT -p tcp -m multiport --dports 443 -j fail2ban-ssh443

-A INPUT -p tcp -m multiport --dports 22 -j fail2ban-ssh

-A fail2ban-ssh -j RETURN

-A fail2ban-ssh443 -j RETURN

COMMIT" > default.rule

/sbin/iptables-restore < default.rule

rm default.rule

}

clean_rule () {

cat $1 | grep -o '[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}' | sort | uniq | awk '{print $1}' | while read IP

if [ "$IP" != "127.0.0.1" ] && [ "$IP" != "122.116.33.14" ] && [ "$IP" != "118.163.31.241" ] ; then

echo iptables -A INPUT -s $IP -j DROP

/sbin/iptables -A INPUT -s $IP -j DROP

done

}

ben_fail_ssh

reset_fw

clean_rule /root/rule/iptables_"$today".rule

backup_rule

技術

How to install cx_Oracle on mac?

step 1.
download software
instantclient-basic-xxxx-xxxx-x64.zip
instantclient-sdk-xxxx-xxxx-x64.zip

step 2.
解壓縮上述檔案到同一路徑

step 3.
create symbolic link
ln -s ~/path/path/libclntsh.dylib.11.1 libclntsh.dylib.11.1
ln -s ~/path/path/libclntsh.dylib.11.1 libclntsh.dylib
ln -s ~/path/path/libocci.dylib.11.1 libocci.dylib.11.1
ln -s ~/path/path/libocci.dylib.11.1 libocci.dylib

step 4.
setup env variable
export ORACLE_HOME=/path/path
export DYLD_LIBRARY_PATH=$ORACLE_HOME
export LD_LIBRARY=$ORACLE_HOME
export PATH=”$ORACLE_HOME:$PATH”

step 5.
disable sip
reboot CMD+R
command line：
csrutil disable

step 6.
install cx_Oracle
pip install cx_Oracle

done…:P

技術

auto restart service for windows

有人來跟我說,有一台service動不動就會死掉,
問我有什麼方法.

我找了找,又動手寫了一個python….XDD

pstools + python script + 設個定時執行

下面程式碼：
詳情請見https://github.com/CSWANG/auto_restart_service_for_windows/

# -*- coding:  utf-8 -*-
import subprocess
import time
import smtplib
import datetime
import ConfigParser
import os
import sys
import logging

cfg_pstools_path = "c:\pstools"

__version__ = '0.2'

def initLogging(logFilename):
    """Init for logging
    """
    logging.basicConfig(
        level=logging.DEBUG,
        format='%(asctime)s - %(levelname)s - %(message)s',
        datefmt='%Y/%m/%d %H:%M:%S',
        filename=logFilename,
        filemode='a')
    console = logging.StreamHandler()
    console.setLevel(logging.INFO)
    formatter = logging.Formatter('%(asctime)s %(levelname)-8s %(message)s')
    console.setFormatter(formatter)
    logging.getLogger('').addHandler(console)

def check_service(service_name):
    cmd = "%s\psservice.exe" % (cfg_pstools_path)
    pst = subprocess.Popen(
            [cmd, "query", service_name],
            stdout = subprocess.PIPE,
            stderr = subprocess.PIPE
        )

    out, error = pst.communicate()

    if out.find('RUNNING') > 0:
        return True
    else:
        return False

def start_service(service_name):
    cmd = "%s\psservice.exe" % (cfg_pstools_path)
    pst = subprocess.Popen(
            [cmd, "start", service_name],
            stdout = subprocess.PIPE,
            stderr = subprocess.PIPE
        )

    out, error = pst.communicate()

    if pst.returncode is not 0:
        return False
    return True

def mail(serverURL=None, strFrom='', strTo='', subject='', text=''):
    smtp = smtplib.SMTP()
    smtp.connect(serverURL)
    for x in strTo:
        headers = 'From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n' % (
            strFrom, x, subject)
        message = headers + text
        smtp.sendmail(strFrom, x, message)
    smtp.quit()

def main():
    start_time = datetime.datetime.now().strftime('%Y_%m_%d %H:%M:%S')
    path = os.path.realpath(os.path.dirname(sys.argv[0]))
    cnf_file = path + '\ps_check_service.cnf'
    config = ConfigParser.ConfigParser()
    config.read(cnf_file)
    service_list = [e.strip() for e in config.get('main', 'service_list').split(',')]
    error_code = 0

    logfile = path + '\ps_check_service.log'
    initLogging(logfile)
    logging.info('check service %s version: %s' % (start_time, __version__))
    
    if os.path.exists("script_status.txt"):
        logging.info('system is running or last time error, please check %s version:%s' % (start_time, __version__))
        service_list = []
        error_code = 1
    else:
        f = file("script_status.txt", "w")
        f.write(start_time)
        f.close()

    check_time = {}
    wait_time = 300
    mailserver = config.get('main', 'mailserver')
    sent = config.get('main', 'sent')

    contacts = [e.strip() for e in config.get('main', 'contacts').split(',')]

    for i in service_list:
        out = check_service(i)
        logging.info("check %s" % (i))

        if out == False:
            start_service(i)
            logging.info("service: %s" % (i))
            logging.info("service restart")
            logging.info("wait: %s" % (90))
            time.sleep(90)
            out = check_service(i)
            if out == False:
                check_time[i] = 1
                while check_time[i] < 3:
                    logging.info("wait_time: %s" % (wait_time))
                    time.sleep(wait_time)
                    start_service(i)
                    logging.info("service: %s service restart" % (i))
                    logging.info("wait: %s" % (90))
                    time.sleep(90)
                    out = check_service(i)
                    if out == False:
                        a = check_time[i]
                        a = a + 1
                        check_time[i] = a
                        error_code = 1
                    else:
                        error_code = 0
                if out == False and error == 1:
                    now = datetime.datetime.now().strftime('%Y_%m_%d %H:%M:%S')
                    subject = 'sapb1 %s service is down, please check %s' % (i, now)
                    msg = 'sapb1 %s service is down, please check %s' % (i, now)
                    logging.info("restart %s service is fail, time: %s" % (i, now))
                    mail(mailserver, sent, contacts, subject, msg)

    if error_code == 0:
        logging.info("check all done")
        os.remove("script_status.txt")

if __name__ == '__main__':
    main()

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

# -*- coding: utf-8 -*-

import subprocess

import time

import smtplib

import datetime

import ConfigParser

import os

import sys

import logging

cfg_pstools_path = "c:\pstools"

__version__ = '0.2'

def initLogging(logFilename):

"""Init for logging

"""

logging.basicConfig(

level=logging.DEBUG,

format='%(asctime)s - %(levelname)s - %(message)s',

datefmt='%Y/%m/%d %H:%M:%S',

filename=logFilename,

filemode='a')

console = logging.StreamHandler()

console.setLevel(logging.INFO)

formatter = logging.Formatter('%(asctime)s %(levelname)-8s %(message)s')

console.setFormatter(formatter)

logging.getLogger('').addHandler(console)

def check_service(service_name):

cmd = "%s\psservice.exe" % (cfg_pstools_path)

pst = subprocess.Popen(

[cmd, "query", service_name],

stdout = subprocess.PIPE,

stderr = subprocess.PIPE

)

out, error = pst.communicate()

if out.find('RUNNING') > 0:

return True

else:

return False

def start_service(service_name):

cmd = "%s\psservice.exe" % (cfg_pstools_path)

pst = subprocess.Popen(

[cmd, "start", service_name],

stdout = subprocess.PIPE,

stderr = subprocess.PIPE

)

out, error = pst.communicate()

if pst.returncode is not 0:

return False

return True

def mail(serverURL=None, strFrom='', strTo='', subject='', text=''):

smtp = smtplib.SMTP()

smtp.connect(serverURL)

for x in strTo:

headers = 'From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n' % (

strFrom, x, subject)

message = headers + text

smtp.sendmail(strFrom, x, message)

smtp.quit()

def main():

start_time = datetime.datetime.now().strftime('%Y_%m_%d %H:%M:%S')

path = os.path.realpath(os.path.dirname(sys.argv[0]))

cnf_file = path + '\ps_check_service.cnf'

config = ConfigParser.ConfigParser()

config.read(cnf_file)

service_list = [e.strip() for e in config.get('main', 'service_list').split(',')]

error_code = 0

logfile = path + '\ps_check_service.log'

initLogging(logfile)

logging.info('check service %s version: %s' % (start_time, __version__))

if os.path.exists("script_status.txt"):

logging.info('system is running or last time error, please check %s version:%s' % (start_time, __version__))

service_list = []

error_code = 1

else:

f = file("script_status.txt", "w")

f.write(start_time)

f.close()

check_time = {}

wait_time = 300

mailserver = config.get('main', 'mailserver')

sent = config.get('main', 'sent')

contacts = [e.strip() for e in config.get('main', 'contacts').split(',')]

for i in service_list:

out = check_service(i)

logging.info("check %s" % (i))

if out == False:

start_service(i)

logging.info("service: %s" % (i))

logging.info("service restart")

logging.info("wait: %s" % (90))

time.sleep(90)

out = check_service(i)

if out == False:

check_time[i] = 1

while check_time[i] < 3:

logging.info("wait_time: %s" % (wait_time))

time.sleep(wait_time)

start_service(i)

logging.info("service: %s service restart" % (i))

logging.info("wait: %s" % (90))

time.sleep(90)

out = check_service(i)

if out == False:

a = check_time[i]

a = a + 1

check_time[i] = a

error_code = 1

else:

error_code = 0

if out == False and error == 1:

now = datetime.datetime.now().strftime('%Y_%m_%d %H:%M:%S')

subject = 'sapb1 %s service is down, please check %s' % (i, now)

msg = 'sapb1 %s service is down, please check %s' % (i, now)

logging.info("restart %s service is fail, time: %s" % (i, now))

mail(mailserver, sent, contacts, subject, msg)

if error_code == 0:

logging.info("check all done")

os.remove("script_status.txt")

if __name__ == '__main__':

main()

技術

virtualbox usb boot for mac

這兩天,我都在弄usb大拇哥 boot

然後我找到
https://www.sebastien-han.fr/blog/2013/12/16/virtualbox-mac-os-x-10-dot-9-boot-from-an-usb-drive/

然後我又覺得上面的步驟好煩,就寫了一個python,來簡化流程…XDD

#-*- coding:  utf-8 -*-
import shlex
import getpass
import os
from subprocess import Popen, PIPE

def get_exitcode_stdout_stderr(cmd):
    """
    Execute the external command and get its exitcode, stdout and stderr.
    """
    args = shlex.split(cmd)

    proc = Popen(args, stdout=PIPE, stderr=PIPE)
    out, err = proc.communicate()
    exitcode = proc.returncode
    #
    return exitcode, out, err

list_disk ='diskutil list'
exitcode, out, err = get_exitcode_stdout_stderr(list_disk)

print out
print 'choose device'

device = raw_input("Enter device path: ")

#print 'umount %s' % (device)

umount_disk = 'diskutil umountdisk %s' % (device)
exitcode, out, err = get_exitcode_stdout_stderr(umount_disk)

password = getpass.getpass("Enter sudo password: ")

echo = Popen(['echo',password],
            stdout=PIPE,
            )
sudo = Popen(['sudo','-S','chmod','777', device],
            stdin=echo.stdout,
            stdout=PIPE,
            )

usb_vmdk = '/Users/csw/Documents/usbdrive.vmdk'
create_usb_vmdk = 'VBoxManage internalcommands createrawvmdk -filename %s -rawdisk %s' % (usb_vmdk, device)

vbox_del = 'vboxmanage unregistervm %s --delete' % ('USB_BOOT')

if os.path.exists(usb_vmdk):
	exitcode, out, err = get_exitcode_stdout_stderr('rm %s' % (usb_vmdk))
	exitcode, out, err = get_exitcode_stdout_stderr(create_usb_vmdk)
else:
	exitcode, out, err = get_exitcode_stdout_stderr(create_usb_vmdk)

print 'execut command:'
print 'umount_disk: %s' % (umount_disk)
print 'chmod: chmod 777 %s' % (device)
print 'create vmbox usb disk: %s' %(create_usb_vmdk)
print 'if you get "error VERR_RESOURCE_BUSY opening image file" message, re execute: %s' %(umount_disk)

#-*- coding: utf-8 -*-

import shlex

import getpass

import os

from subprocess import Popen, PIPE

def get_exitcode_stdout_stderr(cmd):

"""

Execute the external command and get its exitcode, stdout and stderr.

"""

args = shlex.split(cmd)

proc = Popen(args, stdout=PIPE, stderr=PIPE)

out, err = proc.communicate()

exitcode = proc.returncode

return exitcode, out, err

list_disk ='diskutil list'

exitcode, out, err = get_exitcode_stdout_stderr(list_disk)

print out

print 'choose device'

device = raw_input("Enter device path: ")

#print 'umount %s' % (device)

umount_disk = 'diskutil umountdisk %s' % (device)

exitcode, out, err = get_exitcode_stdout_stderr(umount_disk)

password = getpass.getpass("Enter sudo password: ")

echo = Popen(['echo',password],

stdout=PIPE,

)

sudo = Popen(['sudo','-S','chmod','777', device],

stdin=echo.stdout,

stdout=PIPE,

)

usb_vmdk = '/Users/csw/Documents/usbdrive.vmdk'

create_usb_vmdk = 'VBoxManage internalcommands createrawvmdk -filename %s -rawdisk %s' % (usb_vmdk, device)

vbox_del = 'vboxmanage unregistervm %s --delete' % ('USB_BOOT')

if os.path.exists(usb_vmdk):

exitcode, out, err = get_exitcode_stdout_stderr('rm %s' % (usb_vmdk))

exitcode, out, err = get_exitcode_stdout_stderr(create_usb_vmdk)

else:

exitcode, out, err = get_exitcode_stdout_stderr(create_usb_vmdk)

print 'execut command:'

print 'umount_disk: %s' % (umount_disk)

print 'chmod: chmod 777 %s' % (device)

print 'create vmbox usb disk: %s' %(create_usb_vmdk)

print 'if you get "error VERR_RESOURCE_BUSY opening image file" message, re execute: %s' %(umount_disk)

技術

How to Use LUKS to Encrypt a Disk Partition

install software
Ubuntu
apt-get install cryptsetup
aptitude install cryptsetup
Centos
yum install cryptsetup-luks

1. use device or create file

#check device
fdisk -l /dev/sdc
#create file
dd if=/dev/zero of=/root/secret bs=1M count=1024

#check device

fdisk -l /dev/sdc

#create file

dd if=/dev/zero of=/root/secret bs=1M count=1024

2. Encrypt the partition or file:

#device
cryptsetup -q -y luksFormat /dev/sdc1
#file
cryptsetup -q -y luksFormat /root/secret

#device

cryptsetup -q -y luksFormat /dev/sdc1

#file

cryptsetup -q -y luksFormat /root/secret

3. Map a logical partition:

#device
cryptsetup luksOpen /dev/sdc1 crypt_dev
#file
cryptsetup luksOpen /root/secret crypt_dev

#device

cryptsetup luksOpen /dev/sdc1 crypt_dev

#file

cryptsetup luksOpen /root/secret crypt_dev

This will create a device mapper:

#check /dev/mapper
ls -al /dev/mapper/crypt_dev

1 2	#check /dev/mapper ls -al /dev/mapper/crypt_dev

4. Format the encrypted partition:

mkfs.ext3 /dev/mapper/crypt_dev

1	mkfs.ext3 /dev/mapper/crypt_dev

5. Mount the encrypted partition:

mkdir /mnt/crypt_dev
mount /dev/mapper/crypt_dev /mnt/crypt_dev

1 2	mkdir /mnt/crypt_dev mount /dev/mapper/crypt_dev /mnt/crypt_dev

6. When done unmount the logical partition and close (unlock) the encrypted partition

unmount /mnt
cryptsetup luksClose crypt_dev

1 2	unmount /mnt cryptsetup luksClose crypt_dev

技術

RPI fail2ban installation

很久沒寫技術BLOG了,今天來寫一下Fail2ban安裝說明…

網路上總是有人喜歡try ssh的密碼,不知為何就是一直try 一直try,或許人家也是中木馬,或許人家也是逼不得已…XD

因小弟有一個特別需求,無法只使用金鑰認證ssh（習慣上我都是設定ssh key來用）
所以就不得不把password開著…開著就一堆無聊的人一直try..try..try..看到就煩

所以就有請fail2ban來維護一下正義…
安裝方法很簡單
sudo apt-get install fail2ban iptables < --做完改設定/etc/fail2ban/jail.conf [ssh] bantime = -1 <--ban永遠 maxretry = 3 <--try三次就ban ban ban 打完收工... 不過這個做完有一個問題,雖然說設定是寫ban永遠...但是因為rpi的iptable不會紀錄,所以他每次reboot後就全部重來改一下/etc/init.d/fail2ban裡面的設定找到 do_stop() 然後在掛{內加入/sbin/iptables-save > /etc/iptables.conf

and
找 do_start()
找到return 0上一行加上/sbin/iptables-restore < /etc/iptables.conf 這樣reboot規則就不會不見了.... 了解?

技術

daily system check and send mail

真的太懶了…XDD,基本上當系統多到一定程度的時候,就因該進化到異常管理與通知….
人在怎麼勤快,一定會有懶散的時候…
這時候就是想想辦法讓電腦幫我們檢查個個系統的狀態與回報的時候,

前提：你已經裝好Nagios….:P
因Nagios…沒有report的功能…所以我就用python做了一個把網頁轉寄出去的功能…以應付老闆XDD

#!/usr/bin/env python
#-*- coding:  utf-8 -*-
'''
===== Check Spam Report Script =====
Log:
2009/12/20 10:42 ver 0.1 Create Script "The mail system daily check"
2009/12/20 15:40 ver 0.5 add css in the daily report
2010/01/04 14:00 ver 1.0 fix all html link in mail
====================================
'''
from subprocess import call
from email.MIMEMultipart import MIMEMultipart
from email.MIMEText import MIMEText
from email.MIMEImage import MIMEImage

import os
import sys
import urllib
import smtplib
import time
import re

__author__ = "AllenWang"
__copyright__ = "Copyright 2009, SYSTEM CHECK FOR MAIL REPORT Project"
__credits__ = "Allen Wang"
__license__ = "GPL"
__version__ = "1.0"
__maintainer__ = "Allen Wang"
__email__ = "allencswang@gmail.com"
__status__ = "Released"

def getstate(url, file):
    '''GET INFORMATION FROM NAGIOS WEB SITE'''
    #url = "http://nagios.XXXX.com/nagios/cgi-bin/status.cgi?hostgroup=dominoserver&amp;style=detail"
    #file = "system_state.txt"
    wp = urllib.urlopen(url)
    content = wp.read()

    fp = open(file,"w")
    fp.write(content)
    fp.close()
    return True

def replace(r_txt, r_url, data):
    '''FIX HTML LINK '''
    #r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/status.cgi'
    #r_txt = 'status.cgi'
    pattern = re.compile(r_txt, re.IGNORECASE)

    fp = open("tmp", "w")
    for line in file(data):
        fp.write(pattern.sub(r_url, line))

    fp.close()
    os.rename("tmp",data)
    return True

def msend_html(server, strFrom, strTo, subject, file):
    '''SEND MAIL'''
    #Define these once; use them twice!
    #strFrom = 'allen.wang@XXXX.com'
    #strTo = 'allen.wang@XXXX.com'

    #Create the root message and fill in the from, to, and subject headers
    msgRoot = MIMEMultipart('related')
    msgRoot['Subject'] = subject
    msgRoot['From'] = strFrom
    msgRoot['To'] = strTo
    msgRoot.preamble = 'This is a multi-part message in MIME format.'

    #Encapsulate the plain and HTML versions of the message body in an
    #'alternative' part, so message agents can decide which they want to display.
    msgAlternative = MIMEMultipart('alternative')
    msgRoot.attach(msgAlternative)

    msgText = MIMEText('This is the alternative plain text message.')
    msgAlternative.attach(msgText)

    #We reference the image in the IMG SRC attribute by the ID we give it below
    fp = open(file, 'rb')
    msgText = MIMEText(fp.read(), 'html')
    msgAlternative.attach(msgText)
    fp.close()

    #This example assumes the image is in the current directory
    #fp = open('test.jpg', 'rb')
    #msgImage = MIMEImage(fp.read())
    #fp.close()

    #Send the email (this example assumes SMTP authentication is required)
    smtp = smtplib.SMTP()
    smtp.connect(server)
    #smtp.login('exampleuser', 'examplepass')
    smtp.sendmail(strFrom, strTo, msgRoot.as_string())
    smtp.quit()
    return True

def main():
    url = "http://nagios.XXXX.com/nagios/cgi-bin/status.cgi?hostgroup=dominoserver&amp;style=detail"
    file = "system_state.txt"
    r_url = 'http://nagios.XXXX.com/nagios'
    r_txt = "/nagios"
    getstate(url, file)
    replace(r_txt, r_url, file)
    r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/status.cgi'
    r_txt = 'status.cgi'
    replace(r_txt, r_url, file)
    r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/extinfo.cgi'
    r_txt = 'extinfo.cgi'
    replace(r_txt, r_url, file)
    localtime = time.strftime("%H:%M", time.localtime())
    subject = 'The mail system daily report at %s' % (localtime)
    msend_html('10.181.59.137', 'allen.wang@XXXX.com', 'allen.wang@XXXX.com', subject, file)
    os.remove(file)

if __name__ == '__main__':
    main()

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

#!/usr/bin/env python

#-*- coding: utf-8 -*-

'''

===== Check Spam Report Script =====

Log:

2009/12/20 10:42 ver 0.1 Create Script "The mail system daily check"

2009/12/20 15:40 ver 0.5 add css in the daily report

2010/01/04 14:00 ver 1.0 fix all html link in mail

====================================

'''

from subprocess import call

from email.MIMEMultipart import MIMEMultipart

from email.MIMEText import MIMEText

from email.MIMEImage import MIMEImage

import os

import sys

import urllib

import smtplib

import time

import re

__author__ = "AllenWang"

__credits__ = "Allen Wang"

__license__ = "GPL"

__version__ = "1.0"

__maintainer__ = "Allen Wang"

__email__ = "allencswang@gmail.com"

__status__ = "Released"

def getstate(url, file):

'''GET INFORMATION FROM NAGIOS WEB SITE'''

#url = "http://nagios.XXXX.com/nagios/cgi-bin/status.cgi?hostgroup=dominoserver&style=detail"

#file = "system_state.txt"

wp = urllib.urlopen(url)

content = wp.read()

fp = open(file,"w")

fp.write(content)

fp.close()

return True

def replace(r_txt, r_url, data):

'''FIX HTML LINK '''

#r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/status.cgi'

#r_txt = 'status.cgi'

pattern = re.compile(r_txt, re.IGNORECASE)

fp = open("tmp", "w")

for line in file(data):

fp.write(pattern.sub(r_url, line))

fp.close()

os.rename("tmp",data)

return True

def msend_html(server, strFrom, strTo, subject, file):

'''SEND MAIL'''

#Define these once; use them twice!

#strFrom = 'allen.wang@XXXX.com'

#strTo = 'allen.wang@XXXX.com'

#Create the root message and fill in the from, to, and subject headers

msgRoot = MIMEMultipart('related')

msgRoot['Subject'] = subject

msgRoot['From'] = strFrom

msgRoot['To'] = strTo

msgRoot.preamble = 'This is a multi-part message in MIME format.'

#Encapsulate the plain and HTML versions of the message body in an

#'alternative' part, so message agents can decide which they want to display.

msgAlternative = MIMEMultipart('alternative')

msgRoot.attach(msgAlternative)

msgText = MIMEText('This is the alternative plain text message.')

msgAlternative.attach(msgText)

#We reference the image in the IMG SRC attribute by the ID we give it below

fp = open(file, 'rb')

msgText = MIMEText(fp.read(), 'html')

msgAlternative.attach(msgText)

fp.close()

#This example assumes the image is in the current directory

#fp = open('test.jpg', 'rb')

#msgImage = MIMEImage(fp.read())

#fp.close()

#Send the email (this example assumes SMTP authentication is required)

smtp = smtplib.SMTP()

smtp.connect(server)

#smtp.login('exampleuser', 'examplepass')

smtp.sendmail(strFrom, strTo, msgRoot.as_string())

smtp.quit()

return True

def main():

url = "http://nagios.XXXX.com/nagios/cgi-bin/status.cgi?hostgroup=dominoserver&style=detail"

file = "system_state.txt"

r_url = 'http://nagios.XXXX.com/nagios'

r_txt = "/nagios"

getstate(url, file)

replace(r_txt, r_url, file)

r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/status.cgi'

r_txt = 'status.cgi'

replace(r_txt, r_url, file)

r_url = 'http://nagios.XXXX.com/nagios/cgi-bin/extinfo.cgi'

r_txt = 'extinfo.cgi'

replace(r_txt, r_url, file)

localtime = time.strftime("%H:%M", time.localtime())

subject = 'The mail system daily report at %s' % (localtime)

msend_html('10.181.59.137', 'allen.wang@XXXX.com', 'allen.wang@XXXX.com', subject, file)

os.remove(file)

if __name__ == '__main__':

main()

python 讚啦…
搞定收工…:P

技術

Check Spam Report

今天寫了一個script來協助daily check…

沒用到太高級的方法,只是把事情搞定而已….

python,真是一個好物啊…:D

#!/usr/bin/env python
#-*- coding:  utf-8 -*-
'''
===== Check Spam Report Script =====
Log:
2009/12/09 21:58 ver 1.0 Create Script
2009/12/10 13:30 ver 1.1 add localtime
2009/12/11 ver 1.5 add if spam reboot count is equal 0 send massage
2009/12/12 16:02 ver 2.0 The spam report state sent to system
2009/12/29 11:20 ver 2.1 improve send mail in python function
2010/02/02 11:00 ver 2.2 fix sendmail problem
====================================
'''
import smtplib
import sys
import time
import commands

__copyright__ = "Copyright 2009, Check Spam Report Script"  
__create_date__ = '2009/12/09 21:58'
__version__ = '2.2'
__author__ = 'Allen Wang'
__email__ = 'allencswang@gmail.com'
__credits__ = "Allen Wang"  
__license__ = "GPL"  
__maintainer__ = "Allen Wang"  
__status__ = "Released"  

def chklog(sent, chkcount, chktime):
    cmd = 'cat /var/log/maillog |grep "%s" |grep "%s" |wc -l' % (sent, chktime)
    localtime = time.strftime("%H:%M", time.localtime())
    logcount = commands.getoutput(cmd)
    if int(logcount) == 0:
        emsg(logcount,localtime)
    elif int(logcount) < int(chkcount):
        emsg(logcount,localtime)
    else:
        print 'Check time: %s' % (localtime)
        print 'Total sent %s spam report' % (logcount)
        send_state(logcount,localtime)

def emsg(logcount,localtime):
    print 'Check time: %s' % (localtime)
    print 'please check you spam server,because only sent %s spam mail report' % (logcount)
    localtime = time.strftime("%H:%M", time.localtime())
    send_boxsol(logcount,localtime)
    send_yageo(logcount,localtime)

def send_state(logcount,localtime):
    msg = 'check time:%s \nTotal sent %s spam report' % (localtime,logcount)
    subject = 'The Spam Report check state at %s, Total sent %s spam report' % (localtime,logcount)
    contacts = ['xxx@xxx.xxx']
    mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)
    
def send_boxsol(logcount,localtime):
    msg = 'The spam report have problem at %s,because only sent %s spam report to YAGEO users, please check... message from YAGEO Allen mobile:0920576298' % (localtime,logcount)
    subject = 'The Spam Report have problem, please check...'
    contacts =['xxx@xxx.xxx.xxx','xxx@xxx.xxx.xxx','xxx@xxx.xxx.xxx','xxx@xxx.xxx']
    mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)
    
def send_yageo(logcount,localtime):
    msg = 'The spam report have problem at %s,because only sent %s spam report to YAGEO users, please check...' % (localtime,logcount)
    subject = 'The Spam Report have problem, please check...'
    contacts = ["xxx@xxx.xxx.xxx","xxx@xxx.xxx.xxx","xxx@xxx.xxx","xxx@xxx.xxx"]
    mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)
    
def mail(serverURL=None, strFrom='', strTo='', subject='', text=''):
    #headers = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n" % (strFrom, strTo, subject)
    smtp = smtplib.SMTP()
    smtp.connect(serverURL)
    #smtp.login('exampleuser', 'examplepass')
    #smtp.sendmail(strFrom, strTo, message)
    for x in strTo:
    	headers = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n" % (strFrom, x, subject)
    	message = headers + text
	#print x
    	smtp.sendmail(strFrom, x, message)
    smtp.quit()

def main():
    chklog(sent,chkcount,chktime)

if __name__ == '__main__':
        sent = sys.argv[1]
        chkcount = sys.argv[2]
        chktime = sys.argv[3]
        main()

#!/usr/bin/env python

#-*- coding: utf-8 -*-

'''

===== Check Spam Report Script =====

Log:

2009/12/09 21:58 ver 1.0 Create Script

2009/12/10 13:30 ver 1.1 add localtime

2009/12/11 ver 1.5 add if spam reboot count is equal 0 send massage

2009/12/12 16:02 ver 2.0 The spam report state sent to system

2009/12/29 11:20 ver 2.1 improve send mail in python function

2010/02/02 11:00 ver 2.2 fix sendmail problem

====================================

'''

import smtplib

import sys

import time

import commands

__create_date__ = '2009/12/09 21:58'

__version__ = '2.2'

__author__ = 'Allen Wang'

__email__ = 'allencswang@gmail.com'

__credits__ = "Allen Wang"

__license__ = "GPL"

__maintainer__ = "Allen Wang"

__status__ = "Released"

def chklog(sent, chkcount, chktime):

cmd = 'cat /var/log/maillog |grep "%s" |grep "%s" |wc -l' % (sent, chktime)

localtime = time.strftime("%H:%M", time.localtime())

logcount = commands.getoutput(cmd)

if int(logcount) == 0:

emsg(logcount,localtime)

elif int(logcount) < int(chkcount):

emsg(logcount,localtime)

else:

print 'Check time: %s' % (localtime)

print 'Total sent %s spam report' % (logcount)

send_state(logcount,localtime)

def emsg(logcount,localtime):

print 'Check time: %s' % (localtime)

print 'please check you spam server,because only sent %s spam mail report' % (logcount)

localtime = time.strftime("%H:%M", time.localtime())

send_boxsol(logcount,localtime)

send_yageo(logcount,localtime)

def send_state(logcount,localtime):

msg = 'check time:%s \nTotal sent %s spam report' % (localtime,logcount)

subject = 'The Spam Report check state at %s, Total sent %s spam report' % (localtime,logcount)

contacts = ['xxx@xxx.xxx']

mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)

def send_boxsol(logcount,localtime):

msg = 'The spam report have problem at %s,because only sent %s spam report to YAGEO users, please check... message from YAGEO Allen mobile:0920576298' % (localtime,logcount)

subject = 'The Spam Report have problem, please check...'

contacts =['xxx@xxx.xxx.xxx','xxx@xxx.xxx.xxx','xxx@xxx.xxx.xxx','xxx@xxx.xxx']

mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)

def send_yageo(logcount,localtime):

msg = 'The spam report have problem at %s,because only sent %s spam report to YAGEO users, please check...' % (localtime,logcount)

subject = 'The Spam Report have problem, please check...'

contacts = ["xxx@xxx.xxx.xxx","xxx@xxx.xxx.xxx","xxx@xxx.xxx","xxx@xxx.xxx"]

mail('xxx.xxx.xxx.xxx','xxx@xxx.xxx',contacts,subject,msg)

def mail(serverURL=None, strFrom='', strTo='', subject='', text=''):

#headers = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n" % (strFrom, strTo, subject)

smtp = smtplib.SMTP()

smtp.connect(serverURL)

#smtp.login('exampleuser', 'examplepass')

#smtp.sendmail(strFrom, strTo, message)

for x in strTo:

headers = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n" % (strFrom, x, subject)

message = headers + text

#print x

smtp.sendmail(strFrom, x, message)

smtp.quit()

def main():

chklog(sent,chkcount,chktime)

if __name__ == '__main__':

sent = sys.argv[1]

chkcount = sys.argv[2]

chktime = sys.argv[3]

main()

技術

FreeBSD 8 Released

稍早在網路上知道FreeBSD Released了…
也就順手把一台beta,升到released…

步驟如下,
setp 1
#cp /usr/share/examples/cvsup/stable-supfile /root/8release
#vi /root/8release

setp 2
*default host=cvsup.tw.FreeBSD.org
*default release=cvs tag=RELENG_8_0
ps.http://ftp.giga.net.tw/cvsup.php <<---CVSUP更新狀態. setp3 #make installworld && make installkernel #mergemaster #reboot Done...:P

技術

釋放VIM的威力

c9s用Perl寫了一個幫助調整安裝的程式….

超讚~~！！

# cpan Vimana
# vimana search [keyword] [keyword]
# vimana info xml.vim
# vimana install xml.vim

紀錄一下…

Vim Hacks from Lin Yo-An

http://c9s.blogspot.com/2009/08/vim-hacks-coscup.html

Chuan-Shun Wang's BLOG

「求知若飢，虛心若愚。」（Stay hungry. Stay foolish.）

技術

簡單小小script

How to install cx_Oracle on mac?

auto restart service for windows

virtualbox usb boot for mac

How to Use LUKS to Encrypt a Disk Partition

RPI fail2ban installation

daily system check and send mail

Check Spam Report

FreeBSD 8 Released

釋放VIM的威力