In [1]:

    

import monk.core.api as monkapi


    

In [2]:

    

from monk.roles.configuration import get_config


    

In [4]:

    

config = get_config('monk_config.yml', 'console', '')


    

    




[2015-01-16 11:10:30,017][8258 ][monk.roles.configuration][INFO    ][93  ][configuration.py] : configuration done

In [8]:

    

from monk.roles.administrator import AdminBroker as AB


    

In [9]:

    

from monk.roles.worker import WorkerBroker as WB


    

In [10]:

    

from monk.roles.monitor import MonitorBroker as MB


    

In [11]:

    

ab = AB(config.kafkaConnectionString, config.administratorGroup, config.administratorTopic, producerType=AB.FIXED_PRODUCER, producerPartitions=[0])


    

In [13]:

    

wb = WB(config.kafkaConnectionString, config.workerGroup, config.workerTopic, producerType=WB.USER_PRODUCER)


    

In [15]:

    

wb.reconnect()


    

In [16]:

    

mb = MB(config.kafkaConnectionString, config.monitorGroup, config.monitorTopic, producerType=MB.FIXED_PRODUCER, producerPartitions=[0])


    

In [17]:

    

ls


    

    




exper.py        ml-1m-0.test.txt   ml1m-bmf-80.model  monk.console.log           MONK tutorial.ipynb  scientist.yml    xumiao.ipynb
log_config.yml  ml-1m-0.train.txt  monk_config.yml    monk_role_configurations/  MovieLens.ipynb      turtle_scripts/

In [18]:

    

import exper


    

In [20]:

    

userFactors, itemFactors = exper.readModel("ml1m-bmf-80.model")


    

In [21]:

    

userFactors.shape


    

    
Out[21]:





(6040, 80)

In [22]:

    

itemFactors.shape


    

    
Out[22]:





(3685, 80)

In [23]:

    

monkapi.initialize(config)


    

    




[2015-01-16 11:38:34,444][8258 ][monk.api    ][INFO    ][40  ][api.py  ] : ------start up------
[2015-01-16 11:38:34,494][8258 ][monk.uid    ][INFO    ][32  ][uid.py  ] : initializing uid store
[2015-01-16 11:38:34,534][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing EntityStore 
[2015-01-16 11:38:34,534][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing UserStore 
[2015-01-16 11:38:34,535][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing EngineStore 
[2015-01-16 11:38:34,536][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing PandaStore 
[2015-01-16 11:38:34,537][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing MantisStore 
[2015-01-16 11:38:34,538][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing TurtleStore 
[2015-01-16 11:38:34,538][8258 ][monk.crane  ][INFO    ][48  ][crane.py] : initializing TigressStore 






    
Out[23]:





True

In [25]:

    

users = monkapi.crane.userStore.load_all({},['partition','name'])


    

In [ ]: