ficapy

package main

import (
	"log"
	"net"
	"os"
	"os/signal"
	"syscall"
	"time"

ficapy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: ficapy
# Create: '12/12/2017'

import os
import threading
from paramiko import SSHConfig, SSHClient, AutoAddPolicy

HOSTNAME = 'aliyun'

ficapy

POSTGRES_USER=sentry
POSTGRES_PASSWORD=sentry
POSTGRES_DBNAME=sentry

SENTRY_SECRET_KEY=CHANGEME
SENTRY_REDIS_HOST=redis
SENTRY_POSTGRES_HOST=postgres
SENTRY_DB_USER=sentry
SENTRY_DB_PASSWORD=sentry

ficapy

import re
import json
from urllib.parse import urlencode
from config import BEARYCHAT_TOKEN
from tornado.ioloop import IOLoop, PeriodicCallback
from tornado.httpclient import AsyncHTTPClient
from tornado import gen
from tornado.websocket import websocket_connect

ficapy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: ficapy
import threading
import functools
import tornado.ioloop
import tornado.web
from sqlalchemy import Column, create_engine
from sqlalchemy.dialects.mysql import INTEGER, BIT, VARCHAR
from sqlalchemy.ext.declarative import declarative_base

ficapy

# !/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: ficapy

import time
import threading
from threading import Thread
from sqlalchemy import create_engine, Column, Integer
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

ficapy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: ficapy
# Create: '5/25/17'

import inspect
from datetime import datetime
from sqlalchemy import inspection
from collections import namedtuple
from sqlalchemy import create_engine, Column, Integer, String, DateTime

ficapy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: ficapy

from sqlalchemy import create_engine, Column, BIGINT
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

sqlalchemy_db = 'sqlite://'

ficapy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Author: Ficapy
# Create: '12/14/16'

import pytest
from sqlalchemy import create_engine, Column, BIGINT
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.exc import IntegrityError

ficapy

1. 启动celery

   celery -A base_celery worker --loglevel=info 
   

2. 关闭celery(所有任务将丢失不会重启)

pkill -9 -f 'celery worker'