>  기사  >  백엔드 개발  >  데이터베이스 데이터를 얻기 위해 Python으로 작성된 예약된 재실행

데이터베이스 데이터를 얻기 위해 Python으로 작성된 예약된 재실행

高洛峰
高洛峰원래의
2017-02-11 13:23:261814검색

이 글에서는 파이썬을 기반으로 데이터베이스 데이터를 정기적으로 다시 실행하는 방법을 공유하겠습니다. 매우 훌륭하고 참고할만한 가치가 있습니다. 필요하신 분들은 참고해보세요.

하는 아이들 빅 데이터는 종종 예약된 작업을 작성합니다. 데이터를 실행할 때 작업 간의 종속성으로 인해(일반적으로 다운스트림은 업스트림의 데이터 출력에 따라 다름) 많은 사람들이

이후 로그를 확인하기 때문에 데이터 수집에 실패하는 경우가 많습니다. 데이터가 실패했음을 발견한 다음 수동으로 가서 자신의 작업을 수행합니다. 아래에서는 데이터베이스에서 데이터를 검색하기 위한 자동 반복 실행을 구현했습니다. 실패하면 데이터를 얻을 때까지 자동으로 다시 검색합니다.

데이터 테이블 생성:

CREATE TABLE `testtable` ( 2 `id` int(11) unsigned NOT NULL AUTO_INCREMENT, 3 `name` varchar(20) NOT NULL, 4 PRIMARY KEY (`id`) 5 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

처음에는 데이터 테이블이 비어 있고 스크립트가 3초 동안 재시도하면 데이터베이스에 삽입됩니다.

다음은 Python 코드의 구현입니다

#!/usr/bin/env python
 #-*- coning:utf-8 -*- 3 4 import MySQLdb 5 from time import sleep 6 7 class GetData(object): 8 def __init__(self): 9 self.conn = &#39;&#39; 10 self.host = &#39;127.0.0.1&#39; 11 self.port = 3306 12 self.user = &#39;root&#39; 13 self.passwd = &#39;123456&#39; 14 self.db = &#39;test&#39; 15 self.cnum = 5 #set retry number 16 17 def init_connect(self): 18 self.conn = MySQLdb.connect(host=self.host, user=self.user, passwd=self.passwd, db=self.db, port=self.port, 19 charset=&#39;utf8&#39;) 20 21 def get_data(self): 22 self.init_connect 23 cur = self.conn.cursor 24 sql = "select * from testtable" 25 cur.execute(sql) 26 rs = cur.fetchall 27 cur.close 28 self.conn.close 29 return rs 30 31 def run(self): 32 count = 1 33 while (count <= self.cnum): 34 rs = self.get_data 35 if len(rs) > 0: 36 print len(rs) 37 break 38 39 print count 40 sleep(10) 41 count += 1 42 43 if __name__ == &#39;__main__&#39;: 44 gd = GetData 45 gd.run

데이터베이스 데이터를 얻기 위해 Python으로 작성된 예약된 재실행

수동으로 실행할 수 있습니다. 코드가 실행되고 3초 후에 다음 sql을 실행

insert into testtable(`name`) values (&#39;123&#39;),(&#39;456&#39;),(&#39;789&#39;),(&#39;1111&#39;),(&#39;3222&#39;),(&#39;444&#39;);

다음은 예약된 작업의 스크립트입니다

00 08 * * * cd /home/python/lsh_sync; python getdata.py >> getdata.log 2>&1

위 내용은 편집자가 소개한 데이터베이스 데이터를 얻기 위해 Python으로 작성한 예정된 재실행입니다. 궁금한 점이 있으면 메시지를 남겨주세요. 편집자가 제때에 답변해 드릴 것입니다. 또한 PHP 중국어 웹사이트를 지원해 주신 모든 분들께 감사드립니다!

데이터베이스 데이터를 얻기 위해 Python으로 작성된 예정된 재실행과 관련된 더 많은 기사를 보려면 PHP 중국어 웹사이트를 주목하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.