本文整理汇总了Python中st2common.models.db.db_setup函数的典型用法代码示例。如果您正苦于以下问题:Python db_setup函数的具体用法?Python db_setup怎么用?Python db_setup使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了db_setup函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: main
def main():
_monkey_patch()
cli_opts = [
cfg.StrOpt('timestamp', default=None,
help='Will delete data older than ' +
'this timestamp. (default 48 hours). ' +
'Example value: 2015-03-13T19:01:27.255542Z'),
cfg.StrOpt('action-ref', default='',
help='action-ref to delete executions for.')
]
do_register_cli_opts(cli_opts)
config.parse_args()
# Get config values
timestamp = cfg.CONF.timestamp
action_ref = cfg.CONF.action_ref
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
# Connect to db.
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
if not timestamp:
now = datetime.now()
timestamp = now - timedelta(days=DEFAULT_TIMEDELTA_DAYS)
else:
timestamp = datetime.strptime(timestamp, '%Y-%m-%dT%H:%M:%S.%fZ')
# Purge models.
_purge_executions(timestamp=timestamp, action_ref=action_ref)
# Disconnect from db.
db_teardown()
开发者ID:Kailashkatheth1,项目名称:st2,代码行数:35,代码来源:purge_executions.py
示例2: _setup
def _setup():
# Set up logger which logs everything which happens during and before config
# parsing to sys.stdout
logging.setup(DEFAULT_LOGGING_CONF_PATH)
# 1. parse config args
config.parse_args()
# 2. setup logging.
logging.setup(cfg.CONF.sensorcontainer.logging)
# 3. all other setup which requires config to be parsed and logging to
# be correctly setup.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
register_exchanges()
register_common_signal_handlers()
# 4. Register internal triggers
# Note: We need to do import here because of a messed up configuration
# situation (this module depends on configuration being parsed)
from st2common.triggers import register_internal_trigger_types
register_internal_trigger_types()
开发者ID:ravidsinghbiz,项目名称:st2,代码行数:25,代码来源:sensormanager.py
示例3: __init__
def __init__(self, pack, file_path, class_name, trigger_types,
poll_interval=None, parent_args=None):
"""
:param pack: Name of the pack this sensor belongs to.
:type pack: ``str``
:param file_path: Path to the sensor module file.
:type file_path: ``str``
:param class_name: Sensor class name.
:type class_name: ``str``
:param trigger_types: A list of references to trigger types which
belong to this sensor.
:type trigger_types: ``list`` of ``str``
:param poll_interval: Sensor poll interval (in seconds).
:type poll_interval: ``int`` or ``None``
:param parent_args: Command line arguments passed to the parent process.
:type parse_args: ``list``
"""
self._pack = pack
self._file_path = file_path
self._class_name = class_name
self._trigger_types = trigger_types or []
self._poll_interval = poll_interval
self._parent_args = parent_args or []
self._trigger_names = {}
# 1. Parse the config with inherited parent args
try:
config.parse_args(args=self._parent_args)
except Exception:
pass
# 2. Establish DB connection
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
# 3. Instantiate the watcher
self._trigger_watcher = TriggerWatcher(create_handler=self._handle_create_trigger,
update_handler=self._handle_update_trigger,
delete_handler=self._handle_delete_trigger,
trigger_types=self._trigger_types,
queue_suffix='sensorwrapper')
# 4. Set up logging
self._logger = logging.getLogger('SensorWrapper.%s' %
(self._class_name))
logging.setup(cfg.CONF.sensorcontainer.logging)
if '--debug' in parent_args:
set_log_level_for_all_loggers()
self._sensor_instance = self._get_sensor_instance()
开发者ID:langelee,项目名称:st2,代码行数:58,代码来源:sensor_wrapper.py
示例4: initialize
def initialize(self):
# 1. Setup db connection
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password,
ssl=cfg.CONF.database.ssl,
ssl_keyfile=cfg.CONF.database.ssl_keyfile,
ssl_certfile=cfg.CONF.database.ssl_certfile,
ssl_cert_reqs=cfg.CONF.database.ssl_cert_reqs,
ssl_ca_certs=cfg.CONF.database.ssl_ca_certs,
ssl_match_hostname=cfg.CONF.database.ssl_match_hostname)
开发者ID:Bala96,项目名称:st2,代码行数:12,代码来源:unload.py
示例5: _setup
def _setup():
config.parse_args()
# 2. setup logging.
logging.basicConfig(format='%(asctime)s %(levelname)s [-] %(message)s',
level=logging.DEBUG)
# 3. all other setup which requires config to be parsed and logging to
# be correctly setup.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
开发者ID:bjoernbessert,项目名称:st2,代码行数:13,代码来源:bootstrap.py
示例6: _setup
def _setup():
# 1. parse args to setup config.
config.parse_args()
# 2. setup logging.
logging.setup(cfg.CONF.api.logging)
# 3. all other setup which requires config to be parsed and logging to
# be correctly setup.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
开发者ID:bjoernbessert,项目名称:st2,代码行数:13,代码来源:api.py
示例7: main
def main():
config.parse_args()
# Connect to db.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
# Migrate rules.
migrate_rules()
# Disconnect from db.
db_teardown()
开发者ID:Kailashkatheth1,项目名称:st2,代码行数:14,代码来源:migrate_rules_to_include_pack.py
示例8: main
def main():
monkey_patch()
cli_opts = [
cfg.BoolOpt('sensors', default=False,
help='diff sensor alone.'),
cfg.BoolOpt('actions', default=False,
help='diff actions alone.'),
cfg.BoolOpt('rules', default=False,
help='diff rules alone.'),
cfg.BoolOpt('all', default=False,
help='diff sensors, actions and rules.'),
cfg.BoolOpt('verbose', default=False),
cfg.BoolOpt('simple', default=False,
help='In simple mode, tool only tells you if content is missing.' +
'It doesn\'t show you content diff between disk and db.'),
cfg.StrOpt('pack-dir', default=None, help='Path to specific pack to diff.')
]
do_register_cli_opts(cli_opts)
config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
# Connect to db.
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
# Diff content
pack_dir = cfg.CONF.pack_dir or None
content_diff = not cfg.CONF.simple
if cfg.CONF.all:
_diff_sensors(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
_diff_actions(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
_diff_rules(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
return
if cfg.CONF.sensors:
_diff_sensors(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
if cfg.CONF.actions:
_diff_actions(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
if cfg.CONF.rules:
_diff_rules(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
# Disconnect from db.
db_teardown()
开发者ID:AlexeyDeyneko,项目名称:st2,代码行数:49,代码来源:diff-db-disk.py
示例9: main
def main():
_monkey_patch()
cli_opts = [
cfg.BoolOpt("sensors", default=False, help="diff sensor alone."),
cfg.BoolOpt("actions", default=False, help="diff actions alone."),
cfg.BoolOpt("rules", default=False, help="diff rules alone."),
cfg.BoolOpt("all", default=False, help="diff sensors, actions and rules."),
cfg.BoolOpt("verbose", default=False),
cfg.BoolOpt(
"simple",
default=False,
help="In simple mode, tool only tells you if content is missing."
+ "It doesn't show you content diff between disk and db.",
),
cfg.StrOpt("pack-dir", default=None, help="Path to specific pack to diff."),
]
do_register_cli_opts(cli_opts)
config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, "username") else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, "password") else None
# Connect to db.
db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port, username=username, password=password
)
# Diff content
pack_dir = cfg.CONF.pack_dir or None
content_diff = not cfg.CONF.simple
if cfg.CONF.all:
_diff_sensors(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
_diff_actions(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
_diff_rules(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
return
if cfg.CONF.sensors:
_diff_sensors(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
if cfg.CONF.actions:
_diff_actions(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
if cfg.CONF.rules:
_diff_rules(pack_dir=pack_dir, verbose=cfg.CONF.verbose, content_diff=content_diff)
# Disconnect from db.
db_teardown()
开发者ID:azamsheriff,项目名称:st2,代码行数:49,代码来源:diff-db-disk.py
示例10: _setup
def _setup():
# Set up logger which logs everything which happens during and before config
# parsing to sys.stdout
logging.setup(DEFAULT_LOGGING_CONF_PATH)
# 1. parse args to setup config.
config.parse_args()
# 2. setup logging.
logging.setup(cfg.CONF.notifier.logging)
# 3. all other setup which requires config to be parsed and logging to
# be correctly setup.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
register_exchanges()
开发者ID:BlazeMediaGroup,项目名称:st2,代码行数:16,代码来源:st2notifier.py
示例11: db_setup
def db_setup():
username = getattr(cfg.CONF.database, 'username', None)
password = getattr(cfg.CONF.database, 'password', None)
connection = db.db_setup(db_name=cfg.CONF.database.db_name, db_host=cfg.CONF.database.host,
db_port=cfg.CONF.database.port, username=username, password=password)
return connection
开发者ID:ipv1337,项目名称:st2,代码行数:7,代码来源:service_setup.py
示例12: setUpClass
def setUpClass(cls):
super(SensorContainerTestCase, cls).setUpClass()
st2tests.config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password, ensure_indexes=False)
# NOTE: We need to perform this patching because test fixtures are located outside of the
# packs base paths directory. This will never happen outside the context of test fixtures.
cfg.CONF.content.packs_base_paths = PACKS_BASE_PATH
# Register sensors
register_sensors(packs_base_paths=[PACKS_BASE_PATH], use_pack_cache=False)
# Create virtualenv for examples pack
virtualenv_path = '/tmp/virtualenvs/examples'
run_command(cmd=['rm', '-rf', virtualenv_path])
cmd = ['virtualenv', '--system-site-packages', '--python', PYTHON_BINARY, virtualenv_path]
run_command(cmd=cmd)
开发者ID:StackStorm,项目名称:st2,代码行数:25,代码来源:test_sensor_container.py
示例13: _establish_connection_and_re_create_db
def _establish_connection_and_re_create_db(cls):
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
cls._drop_collections()
cls.db_connection.drop_database(cfg.CONF.database.db_name)
开发者ID:Kailashkatheth1,项目名称:st2,代码行数:8,代码来源:base.py
示例14: test_db_setup
def test_db_setup(self, mock_mongoengine):
db_setup(db_name='name', db_host='host', db_port=12345, username='username',
password='password', authentication_mechanism='MONGODB-X509')
call_args = mock_mongoengine.connection.connect.call_args_list[0][0]
call_kwargs = mock_mongoengine.connection.connect.call_args_list[0][1]
self.assertEqual(call_args, ('name',))
self.assertEqual(call_kwargs, {
'host': 'host',
'port': 12345,
'username': 'username',
'password': 'password',
'tz_aware': True,
'authentication_mechanism': 'MONGODB-X509',
'ssl': True,
'ssl_match_hostname': True
})
开发者ID:StackStorm,项目名称:st2,代码行数:18,代码来源:test_db.py
示例15: setUpClass
def setUpClass(cls):
st2tests.config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
DbTestCase.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
cls.drop_collections()
DbTestCase.db_connection.drop_database(cfg.CONF.database.db_name)
开发者ID:bjoernbessert,项目名称:st2,代码行数:9,代码来源:base.py
示例16: _setup
def _setup(argv):
config.parse_args()
# 2. setup logging
log_level = logging.DEBUG
logging.basicConfig(format='%(asctime)s %(levelname)s [-] %(message)s', level=log_level)
if not cfg.CONF.verbose:
# Note: We still want to print things at the following log levels: INFO, ERROR, CRITICAL
exclude_log_levels = [logging.AUDIT, logging.DEBUG]
handlers = logging.getLoggerClass().manager.root.handlers
for handler in handlers:
handler.addFilter(LogLevelFilter(log_levels=exclude_log_levels))
# 3. all other setup which requires config to be parsed and logging to
# be correctly setup.
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
db_setup(cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password)
开发者ID:BlazeMediaGroup,项目名称:st2,代码行数:21,代码来源:bootstrap.py
示例17: _establish_connection_and_re_create_db
def _establish_connection_and_re_create_db(cls):
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password, ensure_indexes=False)
cls._drop_collections()
cls.db_connection.drop_database(cfg.CONF.database.db_name)
# Explicity ensure indexes after we re-create the DB otherwise ensure_indexes could failure
# inside db_setup if test inserted invalid data
db_ensure_indexes()
开发者ID:AlexeyDeyneko,项目名称:st2,代码行数:12,代码来源:base.py
示例18: setUpClass
def setUpClass(cls):
super(SensorContainerTestCase, cls).setUpClass()
return
st2tests.config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password, ensure_indexes=False)
# Register sensors
register_sensors(packs_base_paths=['/opt/stackstorm/packs'], use_pack_cache=False)
# Create virtualenv for examples pack
virtualenv_path = '/opt/stackstorm/virtualenvs/examples'
cmd = ['virtualenv', '--system-site-packages', virtualenv_path]
run_command(cmd=cmd)
开发者ID:AlexeyDeyneko,项目名称:st2,代码行数:19,代码来源:test_sensor_container.py
示例19: setUpClass
def setUpClass(cls):
super(SensorContainerTestCase, cls).setUpClass()
st2tests.config.parse_args()
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password, ensure_indexes=False)
# Register sensors
register_sensors(packs_base_paths=[PACKS_BASE_PATH], use_pack_cache=False)
# Create virtualenv for examples pack
virtualenv_path = '/tmp/virtualenvs/examples'
run_command(cmd=['rm', '-rf', virtualenv_path])
cmd = ['virtualenv', '--system-site-packages', '--python', PYTHON_BINARY, virtualenv_path]
run_command(cmd=cmd)
开发者ID:lyandut,项目名称:st2,代码行数:21,代码来源:test_sensor_container.py
示例20: _establish_connection_and_re_create_db
def _establish_connection_and_re_create_db(cls):
username = cfg.CONF.database.username if hasattr(cfg.CONF.database, 'username') else None
password = cfg.CONF.database.password if hasattr(cfg.CONF.database, 'password') else None
cls.db_connection = db_setup(
cfg.CONF.database.db_name, cfg.CONF.database.host, cfg.CONF.database.port,
username=username, password=password, ensure_indexes=False)
cls._drop_collections()
cls.db_connection.drop_database(cfg.CONF.database.db_name)
# Explicitly ensure indexes after we re-create the DB otherwise ensure_indexes could failure
# inside db_setup if test inserted invalid data.
# NOTE: This is only needed in distributed scenarios (production deployments) where
# multiple services can start up at the same time and race conditions are possible.
if cls.ensure_indexes:
if len(cls.ensure_indexes_models) == 0 or len(cls.ensure_indexes_models) > 1:
msg = ('Ensuring indexes for all the models, this could significantly slow down '
'the tests')
print('#' * len(msg), file=sys.stderr)
print(msg, file=sys.stderr)
print('#' * len(msg), file=sys.stderr)
db_ensure_indexes(cls.ensure_indexes_models)
开发者ID:nzlosh,项目名称:st2,代码行数:23,代码来源:base.py
注:本文中的st2common.models.db.db_setup函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论