python - Celery beat - different time zone per task -


I'm using celery green to determine some functions. I am able to use the CELERY_TIMEZONE setting to schedule tasks using the Contrabab schedule and it runs at scheduled time in the scheduled time zone.

But I want to be able to set more than one such function in the same timezone (single django settings.py) in the same application. I know at what time the job must be run, when the task is being determined

Is it possible to specify a different time zone for each task?

I am using degena (1.4) with celery (3.0.11) and degengo cellari (3.0.11).

I have seen the djcelery.schedulers.DatabaseSudular class and this is the base class, but I can not understand how and how time is being used. Can I write a custom scheduler which can run each job in different timezones?

Thank you,

You have time-zone-aware time of individual tasks in a salary schedule -Certification can be achieved. By specifying different functions for each cellular schedule

This way you can adjust local time in a specific timezone (like adjusting daylight saving time too) Code> Crontab uses it to specify the datetime function, to check if it should run 

  import datetime import pytz nowfun = lambda: datetime.datetime .now (pytz.timezone) ('Europe / Berlin'))   
 In your schedule, Set the date as the time function through   'periodic_task': {'task': 'Api.tasks.asc.asks.periodic', 'schedule': crontab ( Hour = 6, minute = 30, nowfun = nowfun)}   
 It adjusts daily savings on daily 6.30am CET.  
 If you use the function more than once, import partial import from factum import cet_crontab = partial (crontab, nowfun = nowfun) 'periodic_task': consider making a helper  
 > 
  {'Work': 'AP Cask. Make sure you have  CELERY_ENABLE_UTC = incorrect  set, otherwise the celestial ',' schedule ': cet_crontab (hours = 6, minute = 30)}   
 Converts your schedule to UTC.

Comments

Post a Comment

Popular posts from this blog

python - how we can use ajax() in views.py in django? -

I have a little code here. Could you please tell me what this code really does? please. Here in the AJAX call: $ .ajax ({url: "{% url} upload_document '%}", type: "POST", data : {Csrfmiddletoken: document.getElementsByName ('csrfmiddletoken') [0] Price, Title: document.getElementById ('title'). Value, // document: document: document.getElementById ('document'),}, datatype: "Jason", success: function (feedback) {if (feedback == "true") {// success} other {// attachment errors}}}); How AJAX works in the Django and how we can see the AJAX request. Here is the idea of ​​my thoughts def upload_document (requested): Print request. POTT print request FILES if request.is_ajax (): If request.method == 'POST': form = UploadForm (request.POST, request.FILES, user = request.user) if form.is_valid (): Form.save () return HTTPPCS (SimpleJason Dumps ('True'), Mime Type = 'App / Jason') Other:...
Read more

matlab - Using loops to get multiple values into a cell -

I have 31 topics (S1, S2, S3, S4, etc.) 3 images in each topic, opposite 1 IMG, Contrast 2 IMG and Contrast 3 Are IMG I p In a NX1 cell named P, I would like to use a loop to get all the paths of contrasts from all the subjects: data / S1 / contrast1.img / S1 / contrast2.img data / S1 / contrast3.img data / s2 / contrast1.img data / S2 / contrast2.img Data / S2 / contrast3.img ... Data / S31 / contast3.img This is what I've tried: A = {'S1', 'S2', 'S3', ..., 'S31'}; % All topics C = {'contrast1.img', 'contrast2.img', 'contrast3.img'}; For each = P = cell (31 * 3,1) for each topic, the required contrast images: Length = A for Jammu = 1: Length (C) P {j} = spm_select ('FPList', Fullfile (data_path, q {i}) sprint ('% s', cell2mat (c))); % Of each topic is to select three contrast images, it works in my script, it is probably not 100% correct, because I had to simplify this example. End of ...
Read more

python - Sequence Pattern recognition with Pybrain -

Image
I am constantly trying to use recurrent neural networks to classify a series of data. To be more specific, I have a sequence of sensor reading (which is continuous over time), I have to learn an algorithm which can detect the state related to this pattern, given the readings change. Example: Time step_1: 1.4 Time step_2: 1 Time step_3: 0.8 State = New Sequence: Time Phase 1: 0.4 Time Phase 2: 0.3 Time Phase 3: 0.1 State = Sitting I actually have 12 censors, I'm just showing a sequence of numbers for convenience. (Numbers are not real, I'm just trying to fulfill this idea)! I am trying to make my network with PyBrain RNN, however, I can not get a Data Set Container that can detect it, like information I tried to use sequential data But after some testing I came to know that this number is the next element in the sequence of numbers. Here's how I prepare my dataset: self.alldata = SequentialDataSet (ds.num_features, 1) # Now add samples to the dat...
Read more