Permalink
Browse files

Rename taurus.engine to taurus_engine.

  • Loading branch information...
1 parent 9451498 commit b9b771dade69c41d65aa08219e8b0bc4b0cf1d37 @scottpurdy scottpurdy committed May 12, 2016
Showing with 199 additions and 219 deletions.
  1. +0 −20 taurus/taurus/__init__.py
  2. 0 {taurus → taurus_engine}/DEPENDENCIES.md
  3. 0 {taurus → taurus_engine}/Dockerfile
  4. 0 {taurus → taurus_engine}/LICENSE.txt
  5. 0 {taurus → taurus_engine}/README.md
  6. 0 {taurus → taurus_engine}/conf/application.conf
  7. 0 {taurus → taurus_engine}/conf/mime.types
  8. 0 {taurus → taurus_engine}/conf/model-checkpoint.conf
  9. 0 {taurus → taurus_engine}/conf/model-swapper.conf
  10. 0 {taurus → taurus_engine}/conf/nginx-supervisord.conf
  11. 0 {taurus → taurus_engine}/conf/nginx-taurus.conf
  12. 0 {taurus → taurus_engine}/conf/nginx-uwsgi.conf
  13. +2 −2 {taurus → taurus_engine}/conf/supervisord.conf
  14. 0 {taurus → taurus_engine}/docker/configure.sh
  15. 0 {taurus → taurus_engine}/docker/entrypoint.sh
  16. 0 {taurus → taurus_engine}/docker/run.sh
  17. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/Dockerfile
  18. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal.jar
  19. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/antlr-runtime-4.1.jar
  20. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/aws-java-sdk-1.9.16.jar
  21. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/commons-cli-1.2.jar
  22. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/commons-lang3-3.x.jar
  23. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jackson-annotations-2.3.2.jar
  24. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jackson-core-2.3.2.jar
  25. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jackson-databind-2.3.2.jar
  26. BIN ...rus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-ajp-8.1.12.v20130726.jar
  27. BIN ...urus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-annotations-8.1.12.v20130726.jar
  28. BIN ... → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-client-8.1.12.v20130726.jar
  29. BIN ...rus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-continuation-8.1.12.v20130726.jar
  30. BIN ... → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-deploy-8.1.12.v20130726.jar
  31. BIN ...us → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-http-8.1.12.v20130726.jar
  32. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-io-8.1.12.v20130726.jar
  33. BIN ...rus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-jmx-8.1.12.v20130726.jar
  34. BIN ...us → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-jndi-8.1.12.v20130726.jar
  35. BIN ...engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-overlay-deployer-8.1.12.v20130726.jar
  36. BIN ...us → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-plus-8.1.12.v20130726.jar
  37. BIN ... → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-policy-8.1.12.v20130726.jar
  38. BIN ...→ taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-rewrite-8.1.12.v20130726.jar
  39. BIN ... taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-security-8.1.12.v20130726.jar
  40. BIN ... → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-server-8.1.12.v20130726.jar
  41. BIN ...→ taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-servlet-8.1.12.v20130726.jar
  42. BIN ... taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-servlets-8.1.12.v20130726.jar
  43. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-start.jar
  44. BIN ...us → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-util-8.1.12.v20130726.jar
  45. BIN ... → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-webapp-8.1.12.v20130726.jar
  46. BIN ...taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-websocket-8.1.12.v20130726.jar
  47. BIN ...rus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/jetty-xml-8.1.12.v20130726.jar
  48. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/joda-time-2.3.jar
  49. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/libsqlite4java-linux-amd64.so
  50. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/libsqlite4java-linux-i386.so
  51. BIN ...rus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/libsqlite4java-osx-10.4.jnilib
  52. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/libsqlite4java-osx-ppc.jnilib
  53. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/libsqlite4java-osx.jnilib
  54. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/log4j-1.2.17.jar
  55. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/servlet-api-3.0.jar
  56. BIN ...rus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/spdy-core-8.1.12.v20130726.jar
  57. BIN ...us → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/spdy-jetty-8.1.12.v20130726.jar
  58. BIN ...taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/spdy-jetty-http-8.1.12.v20130726.jar
  59. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/sqlite4java-win32-x64.dll
  60. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/sqlite4java-win32-x86.dll
  61. BIN {taurus → taurus_engine}/external/dynamodb_test_tool/DynamoDBLocal_lib/sqlite4java.jar
  62. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/LICENSE.txt
  63. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/README.txt
  64. 0 ...aurus_engine}/external/dynamodb_test_tool/third_party_licenses/THIRD_PARTY_JAVASCRIPT_NOTICES.txt
  65. 0 ...s → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/antlr-runtime-4.1_LICENSE.txt
  66. 0 ...rus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/commons-cli-1.2_LICENSE.txt
  67. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/commons-cli-1.2_NOTICE.txt
  68. 0 ... → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/commons-lang-3.3.x_LICENSE.txt
  69. 0 ...s → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/commons-lang-3.3.x_NOTICE.txt
  70. 0 ...rus_engine}/external/dynamodb_test_tool/third_party_licenses/jackson-annotations-2.3.2_NOTICE.txt
  71. 0 ...s → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/jackson-core-2.3.2_NOTICE.txt
  72. 0 ...taurus_engine}/external/dynamodb_test_tool/third_party_licenses/jackson-databind-2.3.2_NOTICE.txt
  73. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/jackson_LICENSE.txt
  74. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/jetty_LICENSE.txt
  75. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/jetty_NOTICE.txt
  76. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/joda-time-2.3_LICENSE.txt
  77. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/joda-time-2.3_NOTICE.txt
  78. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/log4j-1.2.17_LICENSE.txt
  79. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/log4j-1.2.17_NOTICE.txt
  80. 0 ...rus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/servlet-api-3.0_LICENSE.txt
  81. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/servlet-api-3.0_NOTICE.txt
  82. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/spdy-core_LICENSE.txt
  83. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/spdy-core_NOTICE.txt
  84. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/spdy-jetty_LICENSE.txt
  85. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/spdy-jetty_NOTICE.txt
  86. 0 {taurus → taurus_engine}/external/dynamodb_test_tool/third_party_licenses/sqlite4java_LICENSE.txt
  87. 0 {taurus → taurus_engine}/infrastructure/taurus-service-helper
  88. 0 {taurus → taurus_engine}/pytest.ini
  89. 0 {taurus → taurus_engine}/requirements.txt
  90. +2 −2 {taurus → taurus_engine}/setup.py
  91. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/__init__.py
  92. +4 −4 {taurus/taurus/engine → taurus_engine/taurus_engine}/check_model_consistency.py
  93. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/exceptions.py
  94. +5 −5 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/__init__.py
  95. +1 −1 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/migrate.py
  96. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/migrations/alembic.ini
  97. +2 −2 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/migrations/env.py
  98. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/migrations/script.py.mako
  99. 0 ...taurus_engine/taurus_engine}/repository/migrations/versions/000_57ab75d58038_initial_htmengine.py
  100. 0 ...s_engine/taurus_engine}/repository/migrations/versions/001_1d2eddc43366_timestatmp_to_datetime.py
  101. 0 ...us_engine}/repository/migrations/versions/002_a60d03066072_fix_datetime_and_timestamp_defaults.py
  102. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/schema.py
  103. +1 −1 {taurus/taurus/engine → taurus_engine/taurus_engine}/repository/set_sql_login.py
  104. +6 −6 {taurus/taurus/engine → taurus_engine/taurus_engine}/reset_all_taurus_engine_data.py
  105. 0 {taurus/tests/unit/webservices → taurus_engine/taurus_engine/runtime}/__init__.py
  106. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/__init__.py
  107. +4 −4 {taurus/taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/definitions/__init__.py
  108. 0 ...s/taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/definitions/dynamodbdefinition.py
  109. +7 −7 ...rus_engine/taurus_engine}/runtime/dynamodb/definitions/instance_data_hourly_dynamodbdefinition.py
  110. +5 −5 ...ine → taurus_engine/taurus_engine}/runtime/dynamodb/definitions/metric_data_dynamodbdefinition.py
  111. +5 −5 ...s/engine → taurus_engine/taurus_engine}/runtime/dynamodb/definitions/metric_dynamodbdefinition.py
  112. +6 −6 ...e → taurus_engine/taurus_engine}/runtime/dynamodb/definitions/metric_tweets_dynamodbdefinition.py
  113. +12 −12 {taurus/taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/dynamodb_service.py
  114. +2 −2 .../taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/migrate_metric_data_to_dynamodb.py
  115. +2 −2 {taurus/taurus/engine → taurus_engine/taurus_engine}/runtime/dynamodb/set_dynamodb_credentials.py
  116. +3 −3 {taurus/taurus/engine → taurus_engine/taurus_engine}/set_api_key.py
  117. +1 −1 {taurus/taurus/engine → taurus_engine/taurus_engine}/set_rabbitmq_login.py
  118. +1 −1 {taurus/taurus/engine → taurus_engine/taurus_engine}/taurus_logging.py
  119. +1 −1 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/__init__.py
  120. +4 −4 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/custom_api.py
  121. +5 −5 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/handlers.py
  122. +5 −5 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/instances_api.py
  123. +2 −2 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/metrics_api.py
  124. +6 −6 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/models_api.py
  125. 0 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/responses.py
  126. 0 ...aurus/engine → taurus_engine/taurus_engine}/webservices/schemas/custom_model_creation_schema.json
  127. +2 −2 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/utils.py
  128. +3 −3 {taurus/taurus/engine → taurus_engine/taurus_engine}/webservices/webapp.py
  129. 0 {taurus → taurus_engine}/tests/deployment/README.md
  130. 0 {taurus/tests/unit/runtime/dynamodb → taurus_engine/tests/deployment}/__init__.py
  131. 0 {taurus → taurus_engine}/tests/deployment/health_check_test.py
  132. +7 −7 {taurus → taurus_engine}/tests/deployment/resource_accessibility_test.py
  133. 0 {taurus/tests/unit/runtime → taurus_engine/tests/integration}/__init__.py
  134. 0 {taurus/tests/integration/webservices → taurus_engine/tests/integration/runtime}/__init__.py
  135. 0 {taurus → taurus_engine}/tests/integration/runtime/dynamodb/__init__.py
  136. +7 −7 {taurus → taurus_engine}/tests/integration/runtime/dynamodb/dynamodb_service_test.py
  137. 0 {taurus/tests/integration/runtime → taurus_engine/tests/integration/webservices}/__init__.py
  138. +4 −4 {taurus → taurus_engine}/tests/integration/webservices/models_api_test.py
  139. +28 −28 {taurus → taurus_engine}/tests/unit/check_model_consistency_test.py
  140. +21 −21 {taurus → taurus_engine}/tests/unit/reset_all_taurus_engine_data_test.py
  141. 0 {taurus/tests/integration → taurus_engine/tests/unit/runtime}/__init__.py
  142. 0 {taurus/tests/deployment → taurus_engine/tests/unit/runtime/dynamodb}/__init__.py
  143. +15 −15 {taurus → taurus_engine}/tests/unit/runtime/dynamodb/dynamodb_service_test.py
  144. +7 −7 {taurus → taurus_engine}/tests/unit/set_api_key_test.py
  145. 0 {taurus/taurus/engine/runtime → taurus_engine/tests/unit/webservices}/__init__.py
  146. +10 −10 {taurus → taurus_engine}/tests/unit/webservices/models_api_test.py
  147. +1 −1 taurus_monitoring/taurus_monitoring/metric_order_monitor/metric_order_monitor.py
@@ -1,20 +0,0 @@
-# ----------------------------------------------------------------------
-# Numenta Platform for Intelligent Computing (NuPIC)
-# Copyright (C) 2015, Numenta, Inc. Unless you have purchased from
-# Numenta, Inc. a separate commercial license for this software code, the
-# following terms and conditions apply:
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU Affero Public License version 3 as
-# published by the Free Software Foundation.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
-# See the GNU Affero Public License for more details.
-#
-# You should have received a copy of the GNU Affero Public License
-# along with this program. If not, see http://www.gnu.org/licenses.
-#
-# http://numenta.org/licenses/
-# ----------------------------------------------------------------------
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
@@ -46,7 +46,7 @@ serverurl=http://:
;*************** TAURUS-API **************
[program:taurus-api]
-command=uwsgi --enable-threads --socket 0.0.0.0:19002 --master --vacuum --idle 300 --processes 8 --threads 4 --listen 128 --module taurus.engine.webservices.webapp
+command=uwsgi --enable-threads --socket 0.0.0.0:19002 --master --vacuum --idle 300 --processes 8 --threads 4 --listen 128 --module taurus_engine.webservices.webapp
process_name=%(program_name)s_%(process_num)02d
directory=%(here)s/..
stdout_logfile_maxbytes=50MB
@@ -73,7 +73,7 @@ stopsignal=INT
;*************** DYNAMODB SERVICE **************
[program:dynamodb-service]
-command=python -m taurus.engine.runtime.dynamodb.dynamodb_service
+command=python -m taurus_engine.runtime.dynamodb.dynamodb_service
process_name=%(program_name)s_%(process_num)02d
directory=%(here)s/..
numprocs=2
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
@@ -35,7 +35,7 @@ def run(self):
cmd = [
sys.executable,
"-m",
- "taurus.engine.reset_all_taurus_engine_data"
+ "taurus_engine.reset_all_taurus_engine_data"
]
if self.suppress_prompt_and_obliterate:
@@ -49,7 +49,7 @@ def run(self):
for line in open("requirements.txt").readlines()]
-name = "taurus.engine"
+name = "taurus_engine"
setup(
@@ -37,11 +37,11 @@
from htmengine.repository.queries import MetricStatus
-from taurus.engine import logging_support
-from taurus.engine import repository
+from taurus_engine import logging_support
+from taurus_engine import repository
-from taurus.engine.runtime.dynamodb import dynamodb_service
-from taurus.engine.runtime.dynamodb.definitions import (
+from taurus_engine.runtime.dynamodb import dynamodb_service
+from taurus_engine.runtime.dynamodb.definitions import (
MetricDynamoDBDefinition)
@@ -26,10 +26,10 @@
from nta.utils import sqlalchemy_utils
-from taurus.engine import config
-from taurus.engine import logging_support
-from taurus.engine.repository import schema
-from taurus.engine.repository.migrate import migrate
+from taurus_engine import config
+from taurus_engine import logging_support
+from taurus_engine.repository import schema
+from taurus_engine.repository.migrate import migrate
import htmengine.repository
from htmengine.repository import (addMetric,
addMetricData,
@@ -96,7 +96,7 @@ def engineFactory(reset=False):
Usage::
- from taurus.engine import repository
+ from taurus_engine import repository
engine = repository.engineFactory()
"""
return htmengine.repository.engineFactory(config, reset)
@@ -30,7 +30,7 @@
import pkg_resources
ALEMBIC_CONFIG = alembic.config.Config(pkg_resources.resource_filename(
- "taurus.engine", os.path.join("repository", "migrations", "alembic.ini")))
+ "taurus_engine", os.path.join("repository", "migrations", "alembic.ini")))
@@ -25,8 +25,8 @@
from sqlalchemy import engine_from_config, pool
from logging.config import fileConfig
-from taurus.engine import repository
-from taurus.engine.repository import schema
+from taurus_engine import repository
+from taurus_engine.repository import schema
# this is the Alembic Config object, which provides
# access to the values within the .ini file in use.
@@ -32,7 +32,7 @@
from nta.utils.config import Config
-from taurus.engine import config, logging_support
+from taurus_engine import config, logging_support
@@ -39,10 +39,10 @@
from htmengine.model_checkpoint_mgr import model_checkpoint_mgr
from htmengine import model_swapper
-import taurus.engine
-from taurus.engine import logging_support
-import taurus.engine.repository
-from taurus.engine.runtime.dynamodb.dynamodb_service import DynamoDBService
+import taurus_engine
+from taurus_engine import logging_support
+import taurus_engine.repository
+from taurus_engine.runtime.dynamodb.dynamodb_service import DynamoDBService
@@ -120,7 +120,7 @@ def _cleanRabbitmq():
"""Delete Taurus Engine-related message queues and exchanges"""
g_log.info("Deleting Taurus Engine-related message queues and exchanges")
- appConfig = taurus.engine.config
+ appConfig = taurus_engine.config
modelSwapperConfig = model_swapper.ModelSwapperConfig()
@@ -163,7 +163,7 @@ def _cleanRepository():
"""Reset Taurus Engine's repository database"""
g_log.info("Resetting repository")
- taurus.engine.repository.reset(suppressPromptAndContinueWithDeletion=True)
+ taurus_engine.repository.reset(suppressPromptAndContinueWithDeletion=True)
@@ -19,11 +19,11 @@
# http://numenta.org/licenses/
# ----------------------------------------------------------------------
-from taurus.engine.runtime.dynamodb.definitions.instance_data_hourly_dynamodbdefinition \
+from taurus_engine.runtime.dynamodb.definitions.instance_data_hourly_dynamodbdefinition \
import InstanceDataHourlyDynamoDBDefinition
-from taurus.engine.runtime.dynamodb.definitions.metric_dynamodbdefinition \
+from taurus_engine.runtime.dynamodb.definitions.metric_dynamodbdefinition \
import MetricDynamoDBDefinition
-from taurus.engine.runtime.dynamodb.definitions.metric_data_dynamodbdefinition \
+from taurus_engine.runtime.dynamodb.definitions.metric_data_dynamodbdefinition \
import MetricDataDynamoDBDefinition
-from taurus.engine.runtime.dynamodb.definitions.metric_tweets_dynamodbdefinition \
+from taurus_engine.runtime.dynamodb.definitions.metric_tweets_dynamodbdefinition \
import MetricTweetsDynamoDBDefinition
@@ -24,8 +24,8 @@
from boto.dynamodb2.fields import HashKey, RangeKey, AllIndex, GlobalAllIndex
-import taurus.engine
-from taurus.engine.runtime.dynamodb.definitions.dynamodbdefinition import (
+import taurus_engine
+from taurus_engine.runtime.dynamodb.definitions.dynamodbdefinition import (
DynamoDBDefinition)
@@ -38,7 +38,7 @@ class InstanceDataHourlyDynamoDBDefinition(DynamoDBDefinition):
@property
def tableName(self):
return ("taurus.instance_data_hourly%s" %
- taurus.engine.config.get("dynamodb", "table_name_suffix"))
+ taurus_engine.config.get("dynamodb", "table_name_suffix"))
@property
@@ -50,10 +50,10 @@ def tableCreateKwargs(self):
],
throughput={
"read": (
- taurus.engine.config.getint("dynamodb",
+ taurus_engine.config.getint("dynamodb",
"instance_data_hourly_throughput_read")),
"write": (
- taurus.engine.config.getint("dynamodb",
+ taurus_engine.config.getint("dynamodb",
"instance_data_hourly_throughput_write"))
},
global_indexes=[
@@ -64,10 +64,10 @@ def tableCreateKwargs(self):
RangeKey("hour")
],
throughput={
- "read": taurus.engine.config.getint(
+ "read": taurus_engine.config.getint(
"dynamodb",
"instance_data_hourly_throughput_read"),
- "write": taurus.engine.config.getint(
+ "write": taurus_engine.config.getint(
"dynamodb",
"instance_data_hourly_throughput_write")
}
@@ -24,8 +24,8 @@
from boto.dynamodb2.fields import HashKey, RangeKey, AllIndex
-import taurus.engine
-from taurus.engine.runtime.dynamodb.definitions.dynamodbdefinition import (
+import taurus_engine
+from taurus_engine.runtime.dynamodb.definitions.dynamodbdefinition import (
DynamoDBDefinition)
@@ -38,7 +38,7 @@ class MetricDataDynamoDBDefinition(DynamoDBDefinition):
@property
def tableName(self):
return ("taurus.metric_data%s" % (
- taurus.engine.config.get("dynamodb", "table_name_suffix")))
+ taurus_engine.config.get("dynamodb", "table_name_suffix")))
@property
@@ -49,9 +49,9 @@ def tableCreateKwargs(self):
RangeKey("timestamp")
],
throughput={
- "read": taurus.engine.config.getint("dynamodb",
+ "read": taurus_engine.config.getint("dynamodb",
"metric_data_throughput_read"),
- "write": taurus.engine.config.getint("dynamodb",
+ "write": taurus_engine.config.getint("dynamodb",
"metric_data_throughput_write")
}
)
@@ -24,8 +24,8 @@
from boto.dynamodb2.fields import HashKey
-import taurus.engine
-from taurus.engine.runtime.dynamodb.definitions.dynamodbdefinition import (
+import taurus_engine
+from taurus_engine.runtime.dynamodb.definitions.dynamodbdefinition import (
DynamoDBDefinition)
@@ -37,7 +37,7 @@ class MetricDynamoDBDefinition(DynamoDBDefinition):
@property
def tableName(self):
- return ("taurus.metric%s" % taurus.engine.config.get("dynamodb",
+ return ("taurus.metric%s" % taurus_engine.config.get("dynamodb",
"table_name_suffix"))
@@ -46,9 +46,9 @@ def tableCreateKwargs(self):
return dict(
schema=[HashKey("uid")],
throughput={
- "read": taurus.engine.config.getint("dynamodb",
+ "read": taurus_engine.config.getint("dynamodb",
"metric_throughput_read"),
- "write": taurus.engine.config.getint("dynamodb",
+ "write": taurus_engine.config.getint("dynamodb",
"metric_throughput_write")
}
)
@@ -24,8 +24,8 @@
from boto.dynamodb2.fields import HashKey, RangeKey, GlobalAllIndex
-import taurus.engine
-from taurus.engine.runtime.dynamodb.definitions.dynamodbdefinition import (
+import taurus_engine
+from taurus_engine.runtime.dynamodb.definitions.dynamodbdefinition import (
DynamoDBDefinition)
@@ -38,7 +38,7 @@ class MetricTweetsDynamoDBDefinition(DynamoDBDefinition):
@property
def tableName(self):
return ("taurus.metric_tweets%s" % (
- taurus.engine.config.get("dynamodb", "table_name_suffix")))
+ taurus_engine.config.get("dynamodb", "table_name_suffix")))
@property
@@ -50,7 +50,7 @@ def tableCreateKwargs(self):
],
throughput={
"read": 1,
- "write": taurus.engine.config.getint("dynamodb",
+ "write": taurus_engine.config.getint("dynamodb",
"metric_tweets_throughput_write")
},
global_indexes=[
@@ -62,10 +62,10 @@ def tableCreateKwargs(self):
],
throughput={
"read": (
- taurus.engine.config.getint("dynamodb",
+ taurus_engine.config.getint("dynamodb",
"metric_tweets_throughput_read")),
"write": (
- taurus.engine.config.getint("dynamodb",
+ taurus_engine.config.getint("dynamodb",
"metric_tweets_throughput_write"))
}
)
@@ -43,10 +43,10 @@
from nta.utils import amqp
from nta.utils.dynamodb_utils import retryOnTransientDynamoDBError
-import taurus.engine
-from taurus.engine import taurus_logging
-from taurus.engine.exceptions import InsufficientConfigurationError
-from taurus.engine.runtime.dynamodb.definitions import (
+import taurus_engine
+from taurus_engine import taurus_logging
+from taurus_engine.exceptions import InsufficientConfigurationError
+from taurus_engine.runtime.dynamodb.definitions import (
InstanceDataHourlyDynamoDBDefinition,
MetricDynamoDBDefinition,
MetricDataDynamoDBDefinition,
@@ -55,7 +55,7 @@
from htmengine import htmengineerrno, utils
from htmengine.runtime.anomaly_service import AnomalyService
-from taurus.engine import logging_support
+from taurus_engine import logging_support
@@ -150,9 +150,9 @@ class DynamoDBService(object):
def __init__(self):
self._modelResultsExchange = (
- taurus.engine.config.get("metric_streamer", "results_exchange_name"))
+ taurus_engine.config.get("metric_streamer", "results_exchange_name"))
self._nonMetricDataExchange = (
- taurus.engine.config.get("non_metric_data", "exchange_name"))
+ taurus_engine.config.get("non_metric_data", "exchange_name"))
self.dynamodb = self.connectDynamoDB()
@@ -228,16 +228,16 @@ def connectDynamoDB():
:raises: InsufficientConfigurationError
"""
- region = taurus.engine.config.get("dynamodb", "aws_region")
+ region = taurus_engine.config.get("dynamodb", "aws_region")
connectKwargs = {
"aws_access_key_id": os.getenv("AWS_ACCESS_KEY_ID", "taurus"),
"aws_secret_access_key": os.getenv("AWS_SECRET_ACCESS_KEY", "taurus"),
- "is_secure": taurus.engine.config.getboolean("dynamodb", "is_secure"),
+ "is_secure": taurus_engine.config.getboolean("dynamodb", "is_secure"),
}
- host = taurus.engine.config.get("dynamodb", "host")
- port = taurus.engine.config.get("dynamodb", "port")
+ host = taurus_engine.config.get("dynamodb", "host")
+ port = taurus_engine.config.get("dynamodb", "port")
if host:
if not port:
@@ -612,7 +612,7 @@ def run(self):
def _configChannel(amqpClient):
amqpClient.requestQoS(
- prefetchCount=taurus.engine.config.getint("dynamodb",
+ prefetchCount=taurus_engine.config.getint("dynamodb",
"prefetch_count"))
try:
Oops, something went wrong.

0 comments on commit b9b771d

Please sign in to comment.