python同步_python如何編寫一個同步程序

❶ python 關於Linux 時間同步

1、cat /opt/sync-time.py

#!/usr/bin/env python
import os
os.system('/usr/sbin/ntpdate 1.1.1.1;/sbin/hwclock -w;');
2、crontab -e
添加
0 0 * * * /opt/sync-time.py
或者
0 0 * * * /usr/sbin/ntpdate 1.1.1.1;/sbin/hwclock -w;

❷ python如何編寫一個同步程序

用線程吧，給你一個簡單的線程實例，真的需要同步的話再做個共享變數，來同步文字和音樂

import threading
import time

class printscreen(threading.Thread):
def __init__(self,name=None):
threading.Thread.__init__(self,name=None)
def run(self):
for i in range(5):
time.sleep(2)
print "print screen"

class music(threading.Thread):
def __init__(self,name=None):
threading.Thread.__init__(self,name=None)
def run(self):
for i in range(10):
time.sleep(1)
print "music"

def test():
p = printscreen("pthread")
m = music("mthread")
p.start()
m.start()
p.join()
m.join()

test()

❸ 如何在Windows通過NTP協議實現伺服器時間同步（python或C實現）

（知道不能發鏈接。）
1.獲取NTP伺服器時間。在pypi找ntplib。有範例。
2.設置windows系統時間。有很多方法。最簡單的可以直接用date命令。也可以用win32API SetSystemTime，這個精度控制好一些，可以設置到ms。

如果要定期對時，設置計劃任務即可。

❹ 用python將幾個mysql資料庫的數據同步到一個mysql裡面

這是我以前寫的一個簡單的查找xml值的一個方法，使用該方法可以比較方便的獲得xml的值，相比xml模塊來說比較輕巧defgetValue(xmlcontent,type):start=''end=''ifxmlcontent.find(start)==-1orxmlcontent.find(end)==-1:return""else:sid=xmlcontent.find(start)+len(type)+2eid=xmlcontent.find(end)returnxmlcontent[sid:eid]例如:a='''Jim12'''name=getValue(a,'name')age=getValue(a,'age')在這獲得了數據之後再寫到資料庫不過是一條簡單的INSERT語句罷了

❺ 使用python同步mysql到redis由於數據較多，一條一條讀出來寫到redis太慢，有沒有可以批量操作的。

MYSQL快速同步數據到Redis
舉例場景：存儲游戲玩家的任務數據，游戲伺服器啟動時將mysql中玩家的數據同步到redis中。
從MySQL中將數據導入到Redis的Hash結構中。當然，最直接的做法就是遍歷MySQL數據，一條一條寫入到Redis中。這樣沒什麼錯，但是速度會非常慢。如果能夠想法使得MySQL的查詢輸出數據直接能夠與Redis命令行的輸入數據協議相吻合，可以節省很多消耗和縮短時間。
Mysql資料庫名稱為：GAME_DB, 表結構舉例：
CREATE TABLE TABLE_MISSION (
playerId int(11) unsigned NOT NULL,
missionList varchar(255) NOT NULL,
PRIMARY KEY (playerId)
);

Redis中的數據結構使用哈希表：
鍵KEY為mission, 哈希域為mysql中對應的playerId, 哈希值為mysql中對應的missionList。數據如下：
[root@iZ23zcsdouzZ ~]# redis-cli
127.0.0.1:6379> hget missions 36598
"{\"10001\":{\"status\":1,\"progress\":0},\"10002\":{\"status\":1,\"progress\":0},\"10003\":{\"status\":1,\"progress\":0},\"10004\":{\"status\":1,\"progress\":0}}"

快速同步方法：
新建一個後綴.sql文件：mysql2redis_mission.sql
內容如下：
SELECT CONCAT(
"*4\r\n",
'$', LENGTH(redis_cmd), '\r\n',
redis_cmd, '\r\n',
'$', LENGTH(redis_key), '\r\n',
redis_key, '\r\n',
'$', LENGTH(hkey), '\r\n',
hkey, '\r\n',
'$', LENGTH(hval), '\r\n',
hval, '\r'
)
FROM (
SELECT
'HSET' as redis_cmd,
'missions' AS redis_key,
playerId AS hkey,
missionList AS hval
FROM TABLE_MISSION
) AS t

創建shell腳本mysql2redis_mission.sh
內容：
mysql GAME_DB --skip-column-names --raw < mission.sql | redis-cli --pipe

Linux系統終端執行該shell腳本或者直接運行該系統命令，即可將mysql資料庫GAME_DB的表TABLE_MISSION數據同步到redis中鍵missions中去。mysql2redis_mission.sql文件就是將mysql數據的輸出數據格式和redis的輸入數據格式協議相匹配，從而大大縮短了同步時間。
經過測試，同樣一份數據通過單條取出修改數據格式同步寫入到redis消耗的時間為5min, 使用上面的sql文件和shell命令，同步完數據僅耗時3s左右。

❻ 用Python同步ntp時，爆出這樣的錯誤，該怎樣解決

你指定的伺服器有問題，換一個就可以了。

importdatetime
importntplib

client=ntplib.NTPClient()
res=client.request('ntp.ubuntu.com')
printdatetime.datetime.fromtimestamp(res.tx_time)

❼ Python編寫一個程序,請使用同步賦值語句實現隨機輸入的兩個變數值的交換

賦值語句是由賦值表達式再加上分號構成的表達式語句。其一般形式為：變數=表達式; 賦值語句的功能和特點都與賦值表達式相同。它是程序中使用最多的語句之一。在賦值語句的使用中需要注意以下幾點： 1.由於在賦值符「=」右邊的表達式也可以又是一個賦值表達式，因此，下述形式變數=(變數=表達式); 是成立的，從而形成嵌套的情形。其展開之後的一般形式為：變數=變數=…=表達式; 例如： a=b=c=d=e=5;按照賦值運算符的右接合性，因此實際上等效於： e=5; d=e; c=d; b=c; a=b; 2.注意在變數說明中給變數賦初值和賦值語句的區別。給變數賦初值是變數說明的一部分，賦初值後的變數與其後的其它同類變數之間仍必須用逗號間隔，而賦值語句則必須用分號結尾。 3.在變數說明中，不允許連續給多個變數賦初值。如下述說明是錯誤的： int a=b=c=5 必須寫為 int a=5,b=5,c=5; 而賦值語句允許連續賦值。 4.注意賦值表達式和賦值語句的區別。賦值表達式是一種表達式，它可以出現在任何允許表達式出現的地方，而賦值語句則不能。

❽ django python 資料庫同步的方案，請幫我想一想

你都打算用django來同步了，哪來得的可否用它來同步的問題呢。

有一個功能叫probe，似乎叫這個名子，你可以用它，根據A庫，自動建立模型。順便說一下foriegnkey在django的模型庫里也是支持的。如果不支持，可能你的foreign key太復雜了。

如果可以自動建立模型，那麼其餘的都不是問題了。不過不建議你這么繞一個大彎路，還要用django去寫同步腳本。它僅僅做管理就可以了。

如果一定要用它做同步，就可以在view里寫一個函數。把你的同步邏輯放進去。然後用crontab設置一個定時任務，去訪問這個URL就好了。

似乎它沒有tomcat里的那種定時任務功能。如果你真的要想有，也有開源的插件下載，不過，這就把事情弄得太復雜了。

django就作為一個輕量級的WEB管理軟體就可以了。如果想做復雜的資料庫功能，還是用php和java。

❾ python多線程怎樣同步

鎖機制
�6�9�6�9threading的Lock類，用該類的acquire函數進行加鎖，用realease函數進行解鎖

import threading
import time

class Num:
def __init__(self):
self.num = 0
self.lock = threading.Lock()
def add(self):
self.lock.acquire()#加鎖，鎖住相應的資源
self.num += 1
num = self.num
self.lock.release()#解鎖，離開該資源
return num

n = Num()
class jdThread(threading.Thread):
def __init__(self,item):
threading.Thread.__init__(self)
self.item = item
def run(self):
time.sleep(2)
value = n.add()#將num加1，並輸出原來的數據和+1之後的數據
print(self.item,value)

for item in range(5):
t = jdThread(item)
t.start()
t.join()#使線程一個一個執行
�6�9�6�9當一個線程調用鎖的acquire()方法獲得鎖時，鎖就進入「locked」狀態。每次只有一個線程可以獲得鎖。如果此時另一個線程試圖獲得這個鎖，該線程就會變為「blocked」狀態，稱為「同步阻塞」（參見多線程的基本概念）。
�6�9�6�9直到擁有鎖的線程調用鎖的release()方法釋放鎖之後，鎖進入「unlocked」狀態。線程調度程序從處於同步阻塞狀態的線程中選擇一個來獲得鎖，並使得該線程進入運行（running）狀態。

信號量
�6�9�6�9信號量也提供acquire方法和release方法，每當調用acquire方法的時候，如果內部計數器大於0，則將其減1，如果內部計數器等於0，則會阻塞該線程，知道有線程調用了release方法將內部計數器更新到大於1位置。

import threading
import time
class Num:
def __init__(self):
self.num = 0
self.sem = threading.Semaphore(value = 3)
#允許最多三個線程同時訪問資源

def add(self):
self.sem.acquire()#內部計數器減1
self.num += 1
num = self.num
self.sem.release()#內部計數器加1
return num

n = Num()
class jdThread(threading.Thread):
def __init__(self,item):
threading.Thread.__init__(self)
self.item = item
def run(self):
time.sleep(2)
value = n.add()
print(self.item,value)

for item in range(100):
t = jdThread(item)
t.start()
t.join()
條件判斷
�6�9�6�9所謂條件變數，即這種機制是在滿足了特定的條件後，線程才可以訪問相關的數據。
�6�9�6�9它使用Condition類來完成，由於它也可以像鎖機制那樣用，所以它也有acquire方法和release方法，而且它還有wait，notify，notifyAll方法。

"""
一個簡單的生產消費者模型，通過條件變數的控制產品數量的增減，調用一次生產者產品就是+1，調用一次消費者產品就會-1.
"""

"""
使用 Condition 類來完成，由於它也可以像鎖機制那樣用，所以它也有 acquire 方法和 release 方法，而且它還有
wait， notify， notifyAll 方法。
"""

import threading
import queue,time,random

class Goods:#產品類
def __init__(self):
self.count = 0
def add(self,num = 1):
self.count += num
def sub(self):
if self.count>=0:
self.count -= 1
def empty(self):
return self.count <= 0

class Procer(threading.Thread):#生產者類
def __init__(self,condition,goods,sleeptime = 1):#sleeptime=1
threading.Thread.__init__(self)
self.cond = condition
self.goods = goods
self.sleeptime = sleeptime
def run(self):
cond = self.cond
goods = self.goods
while True:
cond.acquire()#鎖住資源
goods.add()
print("產品數量:",goods.count,"生產者線程")
cond.notifyAll()#喚醒所有等待的線程--》其實就是喚醒消費者進程
cond.release()#解鎖資源
time.sleep(self.sleeptime)

class Consumer(threading.Thread):#消費者類
def __init__(self,condition,goods,sleeptime = 2):#sleeptime=2
threading.Thread.__init__(self)
self.cond = condition
self.goods = goods
self.sleeptime = sleeptime
def run(self):
cond = self.cond
goods = self.goods
while True:
time.sleep(self.sleeptime)
cond.acquire()#鎖住資源
while goods.empty():#如無產品則讓線程等待
cond.wait()
goods.sub()
print("產品數量:",goods.count,"消費者線程")
cond.release()#解鎖資源

g = Goods()
c = threading.Condition()

pro = Procer(c,g)
pro.start()

con = Consumer(c,g)
con.start()
同步隊列
�6�9�6�9put方法和task_done方法，queue有一個未完成任務數量num，put依次num+1，task依次num-1.任務都完成時任務結束。

import threading
import queue
import time
import random

'''
1.創建一個 Queue.Queue() 的實例，然後使用數據對它進行填充。
2.將經過填充數據的實例傳遞給線程類，後者是通過繼承 threading.Thread 的方式創建的。
3.每次從隊列中取出一個項目，並使用該線程中的數據和 run 方法以執行相應的工作。
4.在完成這項工作之後，使用 queue.task_done() 函數向任務已經完成的隊列發送一個信號。
5.對隊列執行 join 操作，實際上意味著等到隊列為空，再退出主程序。
'''

class jdThread(threading.Thread):
def __init__(self,index,queue):
threading.Thread.__init__(self)
self.index = index
self.queue = queue

def run(self):
while True:
time.sleep(1)
item = self.queue.get()
if item is None:
break
print("序號：",self.index,"任務",item,"完成")
self.queue.task_done()#task_done方法使得未完成的任務數量-1

q = queue.Queue(0)
'''
初始化函數接受一個數字來作為該隊列的容量，如果傳遞的是
一個小於等於0的數，那麼默認會認為該隊列的容量是無限的.
'''
for i in range(2):
jdThread(i,q).start()#兩個線程同時完成任務

for i in range(10):
q.put(i)#put方法使得未完成的任務數量+1

導航:首頁 > 編程語言 > python同步

python同步

與python同步相關的資料