package main
import (
"fmt"
"gorm.io/gorm"
"gorm.io/gorm/schema"
"reflect"
"sync"
)
type Product struct {
gorm.Model
Code string
Price uint
}
func main() {
product, _ := schema.Parse(&Product{}, &sync.Map{}, schema.NamingStrategy{})
fmt.Println(product)
fmt.Println(reflect.TypeOf(product))
}
//打印
//main.Product
//*schema.Schema
nsqlookupd -broadcast-address 192.168.120.1 nsqd -lookupd-tcp-address=192.168.120.1:4160 -lookupd-tcp-address=192.168.120.101:4160 -broadcast-address 192.168.120.1
nsqlookupd -broadcast-address 192.168.120.101 nsqd -lookupd-tcp-address=192.168.120.1:4160 -lookupd-tcp-address=192.168.120.101:4160 -broadcast-address 192.168.120.101
import nsq
import tornado.ioloop
import time
def pub_message():
writer.pub('test', str(time.strftime('%H:%M:%S')).encode("utf-8"), finish_pub)
def finish_pub(conn, data):
print(data)
# 写入两个nsq好处: 1.防止nsqd单点故障 2.防止消息丢失
writer = nsq.Writer(['192.168.120.101:4150', '192.168.120.1:4150'])
tornado.ioloop.PeriodicCallback(pub_message, 1000).start()
nsq.run()
import nsq
def handler(message):
print(message, message.id, message.timestamp, message.attempts, message.body)
return True
# 防止nsqlookup故障
r = nsq.Reader(message_handler=handler,
lookupd_http_addresses=['http://192.168.120.1:4161', 'http://192.168.120.101:4161'],
topic='test', channel='abc', lookupd_poll_interval=15)
nsq.run()
WARNING:nsq.reader:[localhost.localdomain:4150:test:abc] connection closed
import nsq
def handler(message):
print(message, message.body)
return True
r = nsq.Reader(message_handler=handler,
lookupd_http_addresses=['http://192.168.120.101:4161'],
topic='test', channel='abc', lookupd_poll_interval=15)
nsq.run()
import nsq
import tornado.ioloop
import time
def pub_message():
writer.pub('test', str(time.strftime('%H:%M:%S')).encode("utf-8"), finish_pub)
def finish_pub(conn, data):
print(data)
writer = nsq.Writer(['127.0.0.1:4150'])
tornado.ioloop.PeriodicCallback(pub_message, 1000).start()
nsq.run()
import serial
from eventlet import tpool
class SerialSocket(serial.Serial):
def recv(self):
# 读完
if self.in_waiting:
return tpool.execute(self.read, self.in_waiting)
return data
def listen_message():
ss = SerialSocket("com10")
buffer = b''
while True:
data = ss.recv()
if data is not None:
buffer +=data
import serial
from eventlet import tpool, sleep
class SerialSocket(serial.Serial):
def recv(self):
# 读完
if self.in_waiting:
return tpool.execute(self.read, self.in_waiting)
return data
def listen_message():
ss = SerialSocket("com10")
buffer = b''
while True:
data = ss.recv()
if data is not None:
buffer +=data
else:
sleep(0.01)
import serial
from eventlet import tpool
class SerialSocket(serial.Serial):
def recv(self):
# 等待
data = tpool.execute(self.read, 1)
# 读完
while self.in_waiting:
data += tpool.execute(self.read, self.in_waiting)
return data
def listen_message():
ss = SerialSocket("com10")
buffer = b''
while True:
g = evenlet.spawn(ss.recv)
data = g.wait()
buffer +=data
def start_new_thread(function, args=(), kwargs=None):
...
print("hello: ", locals())
g = greenthread.spawn_n(__thread_body, function, args, kwargs)
return get_ident(g)
# -*- coding:utf-8 -*-
# from eventlet import patcher
# original_threading = patcher.original('threading')
import threading as original_threading
import time
import eventlet
eventlet.monkey_patch()
def thread1_run():
while True:
print("thread1:", time.time())
time.sleep(1)
if __name__ == "__main__":
thread1 = original_threading.Thread(target=thread1_run, name="thread1", daemon=True)
print(type(thread1))
thread1.start()
e = eventlet.Event()
e.wait()
class BaseRotatingHandler(logging.FileHandler):
def emit(self, record):
"""
Emit a record.
Output the record to the file, catering for rollover as described
in doRollover().
"""
try:
if self.shouldRollover(record):
self.doRollover()
logging.FileHandler.emit(self, record)
except Exception:
self.handleError(record)
import os
import time
import datetime
import logging
from logging.handlers import RotatingFileHandler
from pathlib import Path
class AutumnRotatingFileHandler(RotatingFileHandler):
"""
日志+大小+支持windows
"""
def __init__(self, filename, mode='a', maxBytes=0, backupCount=99, encoding=None, delay=False, backupDayCount=30):
filename = str(filename)
self.date_format = "%Y%m%d"
self.create_date = self._now_date()
self.backupCount = backupCount
# 保存原始文件名
self.filename = str(Path(filename).absolute())
self.backupDayCount = backupDayCount
RotatingFileHandler.__init__(self, self.last_file_name(filename), mode=mode, maxBytes=maxBytes, backupCount=backupCount, encoding=encoding, delay=delay)
def _now_date(self):
return time.strftime(self.date_format, time.localtime())
def doRollover(self):
"""
Do a rollover, as described in __init__().
"""
# 关闭当前文件
if self.stream:
self.stream.close()
self.stream = None
# 生成最新文件名
suffix = "."+ self._now_date()
self.baseFilename = str(self.filename) + suffix
if self.backupCount > 0:
for i in range(0, self.backupCount):
number_suffix = "{:0>2d}".format(i)
sfn = ".".join([self.baseFilename, number_suffix])
if os.path.exists(sfn):
continue
else:
break
number_suffix = "{:0>2d}".format(i)
self.baseFilename = ".".join([self.baseFilename, number_suffix])
# 删除过期文件
self.deleteExpiredFiles()
# 打开
self.stream = self._open()
self.create_date = self._now_date()
def shouldRollover(self, record):
"""
Determine if rollover should occur.
Basically, see if the supplied record would cause the file to exceed
the size limit we have.
"""
# 文件分割条件1: 日期变化
if self._now_date() != self.create_date:
return 1
if self.stream is None: # delay was set...
self.stream = self._open()
# 文件分割条件1: 文件大小超过限制
if self.maxBytes > 0: # are we rolling over?
msg = "%s\n" % self.format(record)
self.stream.seek(0, 2) #due to non-posix-compliant Windows feature
if self.stream.tell() + len(msg) >= self.maxBytes:
return 1
return 0
def deleteExpiredFiles(self):
"""
删除过期文件
"""
dead_datetime = datetime.datetime.now() - datetime.timedelta(days=self.backupDayCount)
filenames = []
for i in range(1, 3):
date = dead_datetime - datetime.timedelta(days=1)
date_str = date.strftime(self.date_format)
base_name = "%s.%s" % (self.filename, date_str)
filenames.append(base_name)
for j in range(1, self.backupCount):
sfn = "%s.%d" % (base_name, j)
filenames.append(sfn)
# delete file
for filename in filenames:
if os.path.exists(filename):
try:
os.remove(sfn)
except:
pass
def last_file_name(self, filename):
"""
文件名
"""
suffix = "."+self._now_date()
base_filename = str(filename) + suffix
if self.backupCount > 0:
for i in reversed(range(0, self.backupCount)):
number_suffix = "{:0>2d}".format(i)
sfn = ".".join([base_filename, number_suffix])
# 最近存在的文件
if os.path.exists(sfn):
break
else:
continue
number_suffix = "{:0>2d}".format(i)
base_filename = ".".join([base_filename, number_suffix])
return base_filename
exception: [WinError 10054] 远程主机强迫关闭了一个现有的连接。 ... ValueError: file descriptor cannot be a negative integer (-1)
def wait(self, seconds=None):
....
try:
r, w, er = select.select(reader_fds, writer_fds, all_fds, seconds)
# 捕捉异常并移除句柄-1
except ValueError as e:
self.remove_descriptor(-1)
return
except select.error as e:
if support.get_errno(e) == errno.EINTR:
return
elif support.get_errno(e) in BAD_SOCK:
self._remove_bad_fds()
return
else:
raise
import sys
import eventlet
# eventlet.monkey_patch()
httplib2 = eventlet.import_patched('httplib2')
print(httplib2)
print(httplib2.socket)
print("================")
for k,v in sys.modules.items():
if "socket" in k:
print(k, v)
# 打印内容
<module 'httplib2' from 'D:\\workspace\\venv\\xxx\\lib\\site-packages\\httplib2\\__init__.py'>
<module 'eventlet.green.socket' from 'D:\\workspace\\venv\\xxx\\lib\\site-packages\\eventlet\\green\\socket.py'>
================
_socket <module '_socket' from 'c:\\python\\python36\\DLLs\\_socket.pyd'>
socket <module 'socket' from 'c:\\python\\python36\\lib\\socket.py'>
__original_module_socket <module 'socket' from 'c:\\python\\python36\\lib\\socket.py'>
# 说明了什么？
绿化只是替换httplib2模块中的引用属性socket。并未改变sys.modules中的属性
from eventlet.green import socket
import eventlet
httplib2 = eventlet.import_patched('httplib2')
print(httplib2)
print(httplib2.socket)
# 打印
<module 'httplib2' from 'D:\\workspace\\venv\\autumn-secs\\lib\\site-packages\\httplib2\\__init__.py'>
<module 'eventlet.green.socket' from 'D:\\workspace\\venv\\autumn-secs\\lib\\site-packages\\eventlet\\green\\socket.py'>
