runtime package

Subpackages

• runtime.apis package
  • Submodules
  • runtime.apis.data_management_engine module
    • creat_index()
    • create_document_collection_index()
    • delete_db_documents()
    • file_database_import()
    • get_cassandra()
    • get_cassandra_sql()
    • get_cassandra_version()
    • get_data()
    • get_data_sort()
    • get_document_db_collections()
    • get_document_db_list()
    • rename_collection()
    • update_dynamic_parameters()
    • update_dynamic_parameters_multi()
  • runtime.apis.predictor_engine module
    • generate_class()
    • generate_key()
    • get_offer_recommendations()
    • get_personality_recommender()
    • get_spending_personality()
    • invocations()
    • learning()
    • model_detail()
    • predictor_response_preload()
    • predictor_response_preload_kafka()
    • process_batch()
    • put_offer_recommendations()
    • put_personality_recommender()
    • put_spending_personality()
    • refresh()
    • response()
    • run_model_mojo()
  • runtime.apis.restart_controller module
    • restart()
    • restart_app()
  • runtime.apis.runtime_engine module
    • login()
    • no_auth_ping()
    • ping()
  • runtime.apis.worker_utilities module
    • behavior_recommender()
    • close_cassandra()
    • connect_u()
    • estore_recommendations()
    • estore_recommender_non_gsm()
    • file_database_import()
    • get_cassandra()
    • get_cassandra_version()
    • get_file()
    • get_file_list()
    • get_financial_wellness()
    • get_ip()
    • get_property()
    • get_rest()
    • get_spend_personality()
    • gift_recommendations_free()
    • gift_recommendations_purchased()
    • just_for_you()
    • list_to_matrix()
    • matrix_to_list()
    • pull_kafka_topic()
    • push_kafka_topic()
    • put_behavior_recommender()
    • put_connect_u()
    • put_estore_recommendations()
    • put_estore_recommender_non_gsm()
    • put_financial_wellness()
    • put_gift_recommendations()
    • put_just_for_you()
    • refresh()
    • send_get()
    • sql_cassandra()
    • test_kafka_kerberos()
    • update_cassandra_config()
    • update_properties()
    • update_properties_key()
    • upload_file()
  • Module contents

Submodules

runtime.access module

class runtime.access.Authenticate(api_address)

Bases: object

Logs into the ecosystem runtime and retrieves an access token for authentication.

Parameters:

api_address – The url of the ecosystem runtime.

get_auth_headers()

get_server()

runtime.export_to_notebook module

runtime.request_utils module

exception runtime.request_utils.ApiError(*args, **kwargs)

Bases: OSError

There was an ambiguous exception that occurred while handling your request.

exception runtime.request_utils.RequestTypeError(t)

Bases: Exception

Exception raised for non existant request type.

runtime.request_utils.auto_format_params(d)

runtime.request_utils.create(auth, endpoint, json=None, data=None, params=None, ep_arg=None, info=False)

runtime.request_utils.create_only_auth(auth, endpoint, info=False, **kwargs)

runtime.request_utils.create_only_auth_no_error(auth, endpoint, info=False, **kwargs)

runtime.request_utils.get_type(t)

Module contents