my_application.repositories package

Submodules

my_application.repositories.BaselineToMongo module

class my_application.repositories.BaselineToMongo.BaselineToMongo(kafka_server, topic, competition, competition_config)

Bases: object

static classification(message, target_dict, prediction_dict)

consumer = None

mongo_repository = None

static regression(message, prediction_dict, num_records, sum_values)

write()

my_application.repositories.CompetitionRepository module

class my_application.repositories.CompetitionRepository.BaseRepository(host, dbname)

Bases: object

Repository base class. Implements the methods to write or delete rows in the table.

insert_one(): inserts one row in the table

insert_many(): insets multiple rows in the table

delete_one(): deletes one row from the table

cleanup()

delete_one(row)

insert_many(rows)

insert_one(row)

instance = None

class my_application.repositories.CompetitionRepository.Competition(competition_id, name, datastream_id, initial_batch_size, initial_training_time, batch_size, time_interval, start_date, end_date, target_class, file_path, predictions_time_interval, description, code)

Bases: sqlalchemy.ext.declarative.api.Base

batch_size

code

competition_id

datastream

datastream_id

description

end_date

file_path

initial_batch_size

initial_training_time

name

predictions_time_interval

serialize()

start_date

target_class

time_interval

class my_application.repositories.CompetitionRepository.CompetitionRepository(host, dbname)

Bases: my_application.repositories.CompetitionRepository.BaseRepository

Competition repository class.

Implements the methods to retrieve competitions by different condititons.

get_competition_by_id(): Retrieve competition by its ID

set_competition_code(): Update the competition code

get_all_competitions(): Retrieve all competition

get_competition_by_code(): Retrieve the competition by code

get_competitions_by_user(): Retrieve competition for a given user

get_all_competitions(status=None, page=None, step=None)

get_competition_by_code(code)

get_competition_by_id(competition_id)

get_competitions_by_user(user_id, status, page, step)

set_competition_code(competition_id, code)

class my_application.repositories.CompetitionRepository.Datastream(datastream_id, name, description, file_path)

Bases: sqlalchemy.ext.declarative.api.Base

competitions

datastream_id

description

file_path

name

serialize()

class my_application.repositories.CompetitionRepository.DatastreamRepository(host, dbname)

Bases: my_application.repositories.CompetitionRepository.BaseRepository

Competition repository class.

Implements the methods to retrieve competitions by different condititons.

get_competition_by_id(): Retrieve competition by its ID

set_competition_code(): Update the competition code

get_all_competitions(): Retrieve all competition

get_competition_by_code(): Retrieve the competition by code

get_competitions_by_user(): Retrieve competition for a given user

get_all_datastreams(page=None, step=None)

get_datastream_by_id(datastream_id)

class my_application.repositories.CompetitionRepository.Subscription(subscription_id, competition_id, user_id)

Bases: sqlalchemy.ext.declarative.api.Base

competition

competition_id

subscription_id

time_create

user

user_id

class my_application.repositories.CompetitionRepository.SubscriptionRepository(host, dbname)

Bases: my_application.repositories.CompetitionRepository.BaseRepository

Subscription repository class.

Implements the methods to retrieve subscriptions by different condititons.

get_competition_subscribers(): Get users that subscribed to the competition

check_subscription(): Check if a given user is subscribed to a given competition

get_subscription(): Retrieve the subscription for a user

check_subscription(competition_id, user_id)

get_competition_subscribers(competition_id)

get_subscription(competition_id, user_id)

class my_application.repositories.CompetitionRepository.User(user_id, first_name, last_name, email, password, role, confirmed, confirmed_on)

Bases: sqlalchemy.ext.declarative.api.Base

check_password(password)

confirmed

confirmed_on

email

first_name

last_name

password_hash

role

serialize()

set_password(password)

user_id

class my_application.repositories.CompetitionRepository.UserRepository(host, dbname)

Bases: my_application.repositories.CompetitionRepository.BaseRepository

User repository class.

Implements the methods to query the USERS table.

get_user_by_id(): Retrieve user information based on his ID

get_user_by_email(): Retrieve user information based on his email

get_all_users(): List all users

delete_many(): Delete several users at the same time

confirm_user(): Manually confirm user’s registration

confirm_user(user)

delete_many(users)

get_all_users()

get_user_by_email(email)

get_user_by_id(id)

my_application.repositories.KafkaToMongo module

class my_application.repositories.KafkaToMongo.ConsumerToMongo(kafka_server, topic, competition)

Bases: object

Kafka Consumer class for writing to MongoDB.

consumer = None

mongo_repository = None

write()

Writes data to the MongoDB. :return:

Module contents