Module ImportFrom alias alias ImportFrom alias ImportFrom alias alias Import alias Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Str NameLoad Dict Str Str If NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Dict Str BinOpSub Call AttributeLoad NameLoad attr Call NameLoad keyword Num Dict Str Dict Str Str NameLoad Dict Str Str If NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Dict Str BinOpSub Call AttributeLoad NameLoad attr Call NameLoad keyword Num Dict Str Dict Str Str NameLoad Dict Str Str If NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr Dict Str Str Str Dict Str Call AttributeLoad NameLoad attr NameLoad Dict Str NameLoad Dict Str Num attr Str attr Num Assign NameStore Call NameLoad Num If Call NameLoad NameLoad body For NameStore NameLoad body AugAssignAdd NameStore BinOpSub Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str AugAssignDiv NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad Call AttributeLoad NameLoad attr NameLoad attr Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Assign NameStore SubscriptLoad SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Index Str Assign NameStore BinOpDiv NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Dict Str Dict Str BinOpSub Call AttributeLoad NameLoad attr Call NameLoad keyword Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Str NameLoad Dict Str Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str Assign NameStore BinOpDiv NameLoad NameLoad orelse Assign NameStore Num Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Dict Str NameLoad Dict Str Dict Str Str NameLoad Dict Str Num If CompareGt Call NameLoad NameLoad Num body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Dict Str Call AttributeLoad NameLoad attr Dict Str Dict Str Str NameLoad Dict Str Num If CompareGt Call NameLoad NameLoad Num body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Dict Str Num Dict Str Dict Str Str NameLoad Dict Str Num If CompareGt Call NameLoad NameLoad Num body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad Dict Str Dict Str Str NameLoad Dict Str Str If CompareGt Call NameLoad NameLoad Num body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Str orelse Assign NameStore Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr Dict Str Str Str Str Str Str Str Str Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Dict Dict Str Dict Str Str Str Str Str Str Str Str Str NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr keyword NameLoad FunctionDef arguments args defaults body ImportFrom alias Assign NameStore Call NameLoad Str Assign NameStore Call NameLoad Str Assign NameStore Call NameLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Str keyword NameLoad decorator_list Expr Call NameLoad Expr Call NameLoad
N/A tapiriik.database db close_connections tapiriik.settings RABBITMQ_USER_QUEUE_STATS_URL datetime datetime timedelta N/A requests N/A distanceSyncedAggr N/A list N/A N/A N/A db sync_stats aggregate N/A N/A $group N/A _id total None N/A $sum $Distance N/A distanceSyncedAggr N/A N/A distanceSynced N/A N/A distanceSyncedAggr N/A 0 N/A total N/A N/A distanceSynced 0 N/A lastDayDistanceSyncedAggr N/A list N/A N/A N/A db sync_stats aggregate N/A N/A $match N/A Timestamp N/A $gt N/A N/A N/A datetime utcnow N/A timedelta hours 24 N/A $group N/A _id total None N/A $sum $Distance N/A lastDayDistanceSyncedAggr N/A N/A lastDayDistanceSynced N/A N/A lastDayDistanceSyncedAggr N/A 0 N/A total N/A N/A lastDayDistanceSynced 0 N/A lastHourDistanceSyncedAggr N/A list N/A N/A N/A db sync_stats aggregate N/A N/A $match N/A Timestamp N/A $gt N/A N/A N/A datetime utcnow N/A timedelta hours 1 N/A $group N/A _id total None N/A $sum $Distance N/A lastHourDistanceSyncedAggr N/A N/A lastHourDistanceSynced N/A N/A lastHourDistanceSyncedAggr N/A 0 N/A total N/A N/A lastHourDistanceSynced 0 N/A enqueueHead N/A list N/A N/A N/A N/A N/A N/A N/A db users find N/A QueuedAt SynchronizationWorker SynchronizationHostRestriction N/A $lte N/A N/A datetime utcnow None N/A $exists False N/A QueuedAt 1 sort QueuedAt limit 10 N/A enqueueTime N/A timedelta 0 N/A N/A len enqueueHead N/A N/A pendingEnqueueUser enqueueHead N/A N/A enqueueTime N/A N/A N/A datetime utcnow N/A pendingEnqueueUser N/A QueuedAt N/A enqueueTime N/A len enqueueHead N/A rmq_user_queue_stats N/A N/A N/A N/A requests get RABBITMQ_USER_QUEUE_STATS_URL json N/A rmq_user_queue_length N/A N/A rmq_user_queue_stats N/A messages_ready_details N/A avg N/A rmq_user_queue_rate N/A N/A N/A rmq_user_queue_stats N/A message_stats N/A ack_details N/A avg_rate N/A rmq_user_queue_wait_time N/A rmq_user_queue_length rmq_user_queue_rate N/A N/A N/A N/A db sync_worker_stats remove N/A Timestamp N/A $lt N/A N/A N/A datetime utcnow N/A timedelta hours 1 N/A timeUsedAgg N/A list N/A N/A N/A db sync_worker_stats aggregate N/A N/A $group N/A _id total None N/A $sum $TimeTaken N/A totalSyncOps N/A N/A N/A db sync_worker_stats count N/A timeUsedAgg N/A N/A timeUsed N/A N/A timeUsedAgg N/A 0 N/A total N/A avgSyncTime N/A timeUsed totalSyncOps N/A N/A timeUsed 0 N/A avgSyncTime 0 N/A lockedSyncRecords N/A list N/A N/A N/A db users aggregate N/A N/A $match N/A SynchronizationWorker N/A $ne None N/A $group N/A _id count None N/A $sum 1 N/A N/A N/A len lockedSyncRecords 0 N/A N/A lockedSyncRecords N/A N/A lockedSyncRecords N/A 0 N/A count N/A N/A lockedSyncRecords 0 N/A pendingSynchronizations N/A list N/A N/A N/A db users aggregate N/A N/A $match N/A NextSynchronization N/A $lt N/A N/A datetime utcnow N/A $group N/A _id count None N/A $sum 1 N/A N/A N/A len pendingSynchronizations 0 N/A N/A pendingSynchronizations N/A N/A pendingSynchronizations N/A 0 N/A count N/A N/A pendingSynchronizations 0 N/A usersWithErrors N/A list N/A N/A N/A db users aggregate N/A N/A $match N/A NonblockingSyncErrorCount N/A $gt 0 N/A $group N/A _id count None N/A $sum 1 N/A N/A N/A len usersWithErrors 0 N/A N/A usersWithErrors N/A N/A usersWithErrors N/A 0 N/A count N/A N/A usersWithErrors 0 N/A totalErrors N/A list N/A N/A N/A db users aggregate N/A N/A $group N/A _id total None N/A $sum $NonblockingSyncErrorCount N/A N/A N/A len totalErrors 0 N/A N/A totalErrors N/A N/A totalErrors N/A 0 N/A total N/A N/A totalErrors 0 N/A N/A N/A N/A db sync_status_stats insert N/A Timestamp Locked Pending ErrorUsers TotalErrors SyncTimeUsed SyncEnqueueTime SyncQueueHeadTime N/A N/A datetime utcnow lockedSyncRecords pendingSynchronizations usersWithErrors totalErrors timeUsed N/A N/A enqueueTime total_seconds rmq_user_queue_wait_time N/A N/A N/A N/A db stats update N/A N/A $set N/A TotalDistanceSynced LastDayDistanceSynced LastHourDistanceSynced TotalSyncTimeUsed AverageSyncDuration LastHourSynchronizationCount EnqueueTime QueueHeadTime Updated distanceSynced lastDayDistanceSynced lastHourDistanceSynced timeUsed avgSyncTime totalSyncOps N/A N/A enqueueTime total_seconds rmq_user_queue_wait_time N/A N/A datetime utcnow upsert True aggregateCommonErrors N/A N/A N/A N/A bson.code Code N/A map_operation N/A Code function(){if (!this.SyncErrors) return;var errorMatch = new RegExp(/\n([^\n]+)\n\nLOCALS:/);var id = this._id;var svc = this.Service;var now = new Date();this.SyncErrors.forEach(function(error){var message = error.Message.match(errorMatch)[1];var key = {service: svc, stem: message.substring(0, 60)};var recency_score = error.Timestamp ? (now - error.Timestamp)/1000 : 0;emit(key, {count:1, ts_count: error.Timestamp ? 1 : 0, recency: recency_score, connections:[id], exemplar:message});});} N/A reduce_operation N/A Code function(key, item){var reduced = {count:0, ts_count:0, connections:[], recency: 0};var connection_collections = [];item.forEach(function(error){reduced.count+=error.count;reduced.ts_count+=error.ts_count;reduced.recency+=error.recency;reduced.exemplar = error.exemplar;connection_collections.push(error.connections);});reduced.connections = reduced.connections.concat.apply(reduced.connections, connection_collections);return reduced;} N/A finalize_operation N/A Code function(key, res){res.recency_avg = res.recency / res.ts_count;return res;} N/A N/A N/A N/A db connections map_reduce map_operation reduce_operation common_sync_errors finalize finalize_operation N/A N/A N/A aggregateCommonErrors N/A N/A close_connections