ocrd_network package¶
Subpackages¶
- ocrd_network.cli package
- ocrd_network.models package
DBProcessorJobDBProcessorJob.job_idDBProcessorJob.processor_nameDBProcessorJob.path_to_metsDBProcessorJob.workspace_idDBProcessorJob.descriptionDBProcessorJob.stateDBProcessorJob.input_file_grpsDBProcessorJob.output_file_grpsDBProcessorJob.page_idDBProcessorJob.parametersDBProcessorJob.depends_onDBProcessorJob.result_queue_nameDBProcessorJob.callback_urlDBProcessorJob.internal_callback_urlDBProcessorJob.start_timeDBProcessorJob.end_timeDBProcessorJob.exec_timeDBProcessorJob.log_file_pathDBProcessorJob.SettingsDBProcessorJob.to_job_output()
DBWorkflowJobDBWorkspacePYJobInputPYJobInput.processor_namePYJobInput.path_to_metsPYJobInput.workspace_idPYJobInput.descriptionPYJobInput.input_file_grpsPYJobInput.output_file_grpsPYJobInput.page_idPYJobInput.parametersPYJobInput.result_queue_namePYJobInput.callback_urlPYJobInput.agent_typePYJobInput.job_idPYJobInput.depends_onPYJobInput.Config
PYJobOutputPYOcrdToolPYResultMessagePYWorkflowJobOutputStateEnum- Submodules
- ocrd_network.rabbitmq_utils package
RMQConsumerRMQConnectorRMQConnector.declare_and_bind_defaults()RMQConnector.open_blocking_connection()RMQConnector.open_blocking_channel()RMQConnector.exchange_bind()RMQConnector.exchange_declare()RMQConnector.exchange_delete()RMQConnector.exchange_unbind()RMQConnector.queue_bind()RMQConnector.queue_declare()RMQConnector.queue_delete()RMQConnector.queue_purge()RMQConnector.queue_unbind()RMQConnector.set_qos()RMQConnector.confirm_delivery()RMQConnector.basic_publish()
RMQPublisherOcrdProcessingMessageOcrdResultMessage- Submodules
Submodules¶
- ocrd_network.client module
- ocrd_network.database module
initiate_database()sync_initiate_database()db_create_workspace()db_get_workspace()sync_db_get_workspace()db_update_workspace()sync_db_update_workspace()db_get_processing_job()sync_db_get_processing_job()db_update_processing_job()sync_db_update_processing_job()db_get_workflow_job()sync_db_get_workflow_job()db_get_processing_jobs()sync_db_get_processing_jobs()
- ocrd_network.deployer module
DeployerDeployer.find_matching_processors()Deployer.resolve_processor_server_url()Deployer.kill_all()Deployer.deploy_hosts()Deployer.deploy_rabbitmq()Deployer.deploy_mongodb()Deployer.kill_rabbitmq()Deployer.kill_mongodb()Deployer.kill_hosts()Deployer.kill_processing_workers()Deployer.kill_processor_servers()Deployer.start_native_processor()Deployer.start_docker_processor()Deployer.start_native_processor_server()Deployer.start_unix_mets_server()Deployer.stop_unix_mets_server()
- ocrd_network.deployment_utils module
- ocrd_network.logging module
get_root_logging_dir()get_cache_locked_pages_logging_file_path()get_cache_processing_requests_logging_file_path()get_processing_job_logging_file_path()get_processing_server_logging_file_path()get_processing_worker_logging_file_path()get_processor_server_logging_file_path()get_mets_server_logging_file_path()
- ocrd_network.param_validators module
- ocrd_network.process_helpers module
- ocrd_network.processing_server module
ProcessingServerProcessingServer.start()ProcessingServer.on_startup()ProcessingServer.on_shutdown()ProcessingServer.stop_deployed_agents()ProcessingServer.connect_publisher()ProcessingServer.create_message_queues()ProcessingServer.create_processing_message()ProcessingServer.check_if_queue_exists()ProcessingServer.query_ocrd_tool_json_from_server()ProcessingServer.push_processor_job()ProcessingServer.push_to_processing_queue()ProcessingServer.push_to_processor_server()ProcessingServer.get_processor_job()ProcessingServer.get_processor_job_log()ProcessingServer.remove_from_request_cache()ProcessingServer.get_processor_info()ProcessingServer.list_processors()ProcessingServer.task_sequence_to_processing_jobs()ProcessingServer.run_workflow()ProcessingServer.get_workflow_info()
- ocrd_network.processing_worker module
- ocrd_network.processor_server module
ProcessorServerProcessorServer.on_startup()ProcessorServer.on_shutdown()ProcessorServer.get_processor_info()ProcessorServer.create_processor_task()ProcessorServer.run_processor_task()ProcessorServer.get_ocrd_tool()ProcessorServer.get_version()ProcessorServer.run_server()ProcessorServer.get_processor_job()ProcessorServer.get_processor_job_log()
- ocrd_network.runtime_data module
- ocrd_network.server_cache module
- ocrd_network.server_utils module
- ocrd_network.utils module
call_sync()calculate_execution_time()generate_created_time()generate_id()validate_and_load_config()verify_database_uri()verify_and_parse_mq_uri()download_ocrd_all_tool_json()post_to_callback_url()get_ocrd_workspace_instance()get_ocrd_workspace_physical_pages()is_mets_server_running()stop_mets_server()
