AIL/ail-framework
7
0
Fork 0
mirror of https://github.com/ail-project/ail-framework.git synced 2024-11-22 22:27:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: [redis cache] remove old paste_name db

Browse source
This commit is contained in:
Terrtia 2021-04-02 16:43:13 +02:00
parent dca806963c
commit b6da063473
No known key found for this signature in database
GPG key ID: 1E1B1F50D84613D0
2 changed files with 2 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
bin/ModuleStats.py
View file

@ -6,7 +6,7 @@
"""
##################################
# Import External packages
# Import External packages #
##################################
import time
import datetime
@ -15,7 +15,7 @@ import os
##################################
# Import Project packages
# Import Project packages #
##################################
from module.abstract_module import AbstractModule
from packages.Date import Date
@ -47,9 +47,6 @@ class ModuleStats(AbstractModule):
# REDIS #
self.r_serv_trend = ConfigLoader.ConfigLoader().get_redis_conn("ARDB_Trending")
self.r_serv_pasteName = ConfigLoader.ConfigLoader().get_redis_conn("Redis_Paste_Name")
def compute(self, message):
if len(message.split(';')) > 1:
@ -112,7 +109,6 @@ class ModuleStats(AbstractModule):
redis_providers_name_set = 'providers_set_' + paste_date
# Add/Update in Redis
self.r_serv_pasteName.sadd(paste_baseName, message)
self.r_serv_trend.sadd(redis_all_provider, paste_provider)
num_paste = int(self.r_serv_trend.hincrby(paste_provider+'_num', paste_date, 1))

7
bin/Web.py
View file

@ -64,10 +64,6 @@ class Web(AbstractModule):
self.cc_critical = self.process.config.get("Url", "cc_critical")
# FUNCTIONS #
self.redis_logger.info("Script URL subscribed to channel web_categ")
# FIXME For retro compatibility
self.channel = 'web_categ'
self.faup = Faup()
@ -177,9 +173,6 @@ class Web(AbstractModule):
domains_list)
if A_values[0] >= 1:
PST.__setattr__(self.channel, A_values)
PST.save_attribute_redis(self.channel, (A_values[0],
list(A_values[1])))
pprint.pprint(A_values)
# self.redis_logger.info('Url;{};{};{};Checked {} URL;{}'.format(