Warning
This document is for an old release of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.
Source code for galaxy.model.migrate.versions.0026_cloud_tables
"""
This script adds tables needed for Galaxy cloud functionality.
"""
import datetime
import logging
from sqlalchemy import Boolean, Column, DateTime, ForeignKey, Integer, MetaData, Table, TEXT
from galaxy.model.migrate.versions.util import create_table, drop_table
now = datetime.datetime.utcnow
log = logging.getLogger(__name__)
metadata = MetaData()
CloudImage_table = Table("cloud_image", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("provider_type", TEXT),
Column("image_id", TEXT, nullable=False),
Column("manifest", TEXT),
Column("state", TEXT),
Column("architecture", TEXT),
Column("deleted", Boolean, default=False))
""" UserConfiguredInstance (UCI) table """
UCI_table = Table("cloud_uci", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("credentials_id", Integer, ForeignKey("cloud_user_credentials.id"), index=True),
Column("key_pair_name", TEXT),
Column("key_pair_material", TEXT),
Column("name", TEXT),
Column("state", TEXT),
Column("error", TEXT),
Column("total_size", Integer),
Column("launch_time", DateTime),
Column("deleted", Boolean, default=False))
CloudInstance_table = Table("cloud_instance", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("launch_time", DateTime),
Column("stop_time", DateTime),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("uci_id", Integer, ForeignKey("cloud_uci.id"), index=True),
Column("type", TEXT),
Column("reservation_id", TEXT),
Column("instance_id", TEXT),
Column("mi_id", Integer, ForeignKey("cloud_image.id"), index=True),
Column("state", TEXT),
Column("error", TEXT),
Column("public_dns", TEXT),
Column("private_dns", TEXT),
Column("security_group", TEXT),
Column("availability_zone", TEXT))
CloudStore_table = Table("cloud_store", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("attach_time", DateTime),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("uci_id", Integer, ForeignKey("cloud_uci.id"), index=True, nullable=False),
Column("volume_id", TEXT),
Column("size", Integer, nullable=False),
Column("availability_zone", TEXT),
Column("inst_id", Integer, ForeignKey("cloud_instance.id")),
Column("status", TEXT),
Column("device", TEXT),
Column("space_consumed", Integer),
Column("error", TEXT),
Column("deleted", Boolean, default=False))
CloudSnapshot_table = Table("cloud_snapshot", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("uci_id", Integer, ForeignKey("cloud_uci.id"), index=True),
Column("store_id", Integer, ForeignKey("cloud_store.id"), index=True, nullable=False),
Column("snapshot_id", TEXT),
Column("status", TEXT),
Column("description", TEXT),
Column("error", TEXT),
Column("deleted", Boolean, default=False))
CloudUserCredentials_table = Table("cloud_user_credentials", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("provider_id", Integer, ForeignKey("cloud_provider.id"), index=True, nullable=False),
Column("name", TEXT),
Column("access_key", TEXT),
Column("secret_key", TEXT),
Column("deleted", Boolean, default=False))
CloudProvider_table = Table("cloud_provider", metadata,
Column("id", Integer, primary_key=True),
Column("create_time", DateTime, default=now),
Column("update_time", DateTime, default=now, onupdate=now),
Column("user_id", Integer, ForeignKey("galaxy_user.id"), index=True, nullable=False),
Column("type", TEXT, nullable=False),
Column("name", TEXT),
Column("region_connection", TEXT),
Column("region_name", TEXT),
Column("region_endpoint", TEXT),
Column("is_secure", Boolean),
Column("host", TEXT),
Column("port", Integer),
Column("proxy", TEXT),
Column("proxy_port", TEXT),
Column("proxy_user", TEXT),
Column("proxy_pass", TEXT),
Column("debug", Integer),
Column("https_connection_factory", TEXT),
Column("path", TEXT),
Column("deleted", Boolean, default=False))
[docs]def upgrade(migrate_engine):
print(__doc__)
metadata.bind = migrate_engine
metadata.reflect()
create_table(CloudProvider_table)
create_table(CloudUserCredentials_table)
create_table(CloudImage_table)
create_table(UCI_table)
create_table(CloudInstance_table)
create_table(CloudStore_table)
create_table(CloudSnapshot_table)
[docs]def downgrade(migrate_engine):
metadata.bind = migrate_engine
metadata.reflect()
drop_table(CloudSnapshot_table)
drop_table(CloudStore_table)
drop_table(CloudInstance_table)
drop_table(UCI_table)
drop_table(CloudImage_table)
drop_table(CloudUserCredentials_table)
drop_table(CloudProvider_table)