Merge branch 'main' of https://github.com/olinpin/twitter-project
This commit is contained in:
		
							
								
								
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
										Normal file
									
								
							
							
						
						
									
										1
									
								
								.gitignore
									
									
									
									
										vendored
									
									
										Normal file
									
								
							| @@ -0,0 +1 @@ | |||||||
|  | ./sports1.txt | ||||||
| @@ -1,18 +1,20 @@ | |||||||
| from eca import * | from eca import * | ||||||
|  | from eca.generators import start_offline_tweets | ||||||
| 
 | 
 | ||||||
| import random | import random | ||||||
| 
 | 
 | ||||||
| ## You might have to update the root path to point to the correct path | ## You might have to update the root path to point to the correct path | ||||||
| ## (by default, it points to <rules>_static) | ## (by default, it points to <rules>_static) | ||||||
| # root_content_path = 'template_static' | root_content_path = 'dashboard_static' | ||||||
| 
 | 
 | ||||||
| 
 | 
 | ||||||
| # binds the 'setup' function as the action for the 'init' event | # binds the 'setup' function as the action for the 'init' event | ||||||
| # the action will be called with the context and the event | # the action will be called with the context and the event | ||||||
| @event('init') | @event('init') | ||||||
| def setup(ctx, e): | def setup(ctx, e): | ||||||
|  |     start_offline_tweets('sports1.txt', event_name="sample") | ||||||
|     ctx.count = 0 |     ctx.count = 0 | ||||||
|     fire('sample', {'previous': 0.0}) |     # fire('sample', {'previous': 0.0}) | ||||||
| 
 | 
 | ||||||
| 
 | 
 | ||||||
| # define a normal Python function | # define a normal Python function | ||||||
| @@ -24,16 +26,16 @@ def generate_sample(ctx, e): | |||||||
|     ctx.count += 1 |     ctx.count += 1 | ||||||
|     if ctx.count % 50 == 0: |     if ctx.count % 50 == 0: | ||||||
|         emit('debug', {'text': 'Log message #'+str(ctx.count)+'!'}) |         emit('debug', {'text': 'Log message #'+str(ctx.count)+'!'}) | ||||||
| 
 |     tweet = e.data | ||||||
|  |     print(tweet) | ||||||
|     # base sample on previous one |     # base sample on previous one | ||||||
|     sample = clip(-100, e.data['previous'] + random.uniform(+5.0, -5.0), 100) |     # sample = clip(-100, e.data['previous'] + random.uniform(+5.0, -5.0), 100) | ||||||
| 
 |  | ||||||
|     # emit to outside world |     # emit to outside world | ||||||
|     emit('sample',{ |     emit('sample',{ | ||||||
|         'action': 'add', |         'action': 'add', | ||||||
|         'value': sample |         'value': tweet | ||||||
|     }) |     }) | ||||||
| 
 | 
 | ||||||
|     # chain event |     # chain event | ||||||
|     fire('sample', {'previous': sample}, delay=0.05) |     fire('sample', {'previous': tweet}, delay=0.05) | ||||||
| 
 | 
 | ||||||
		Reference in New Issue
	
	Block a user
	 Tim Wijma
					Tim Wijma