Skip to content

Instantly share code, notes, and snippets.

@entzik
entzik / Handler.java
Created May 30, 2018 21:32
Spring Cloud Function AWS Lambda Request Handler
public class Handler extends SpringBootApiGatewayRequestHandler {
}
public interface ClimateReadingRepository extends CrudRepository<ClimateReading, String> {
}
@entzik
entzik / application.properties
Created May 27, 2018 20:03
specifying a function name
...
function.name=saveReadings
...
@entzik
entzik / Application.java
Created May 27, 2018 19:56
Spring Cloud Function Entry Point
@SpringBootApplication
public class Application {
@Autowired
ClimateReadingRepository climateReadingRepository;
@Bean(name = "saveReadings")
public Function<ClimateReading, ClimateReading> saveReadings() {
return (reading) -> climateReadingRepository.save(reading);
}
buildscript {
ext {
springBootVersion = '1.5.11.RELEASE'
wrapperVersion = '1.0.9.RELEASE'
shadowVersion = '2.0.1'
}
repositories {
jcenter()
mavenLocal()
mavenCentral()
@entzik
entzik / threader.py
Last active May 26, 2018 19:58
Raspberry PI AM3203 to Lambda
#!/usr/bin/python
import sys
import Adafruit_DHT
import json
import urllib2
import time
humidity, temperature = Adafruit_DHT.read_retry(Adafruit_DHT.AM2302, 2)
/**
* tske a {@link FilePart}, transfer it to disk using {@link AsynchronousFileChannel}s and return a {@link Mono} representing the result
*
* @param filePart - the request part containing the file to be saved
* @return a {@link Mono} representing the result of the operation
*/
private Mono<String> saveFile(FilePart filePart) {
LOGGER.info("handling file upload {}", filePart.filename());
// if a file with the same name already exists in a repository, delete and recreate it
@RestController
@RequestMapping(path = "/api/files")
public class ReactiveUploadResource {
Logger LOGGER = LoggerFactory.getLogger(ReactiveUploadResource.class);
/**
* upload handler method, mapped to POST. Like any file upload handler it consumes MULTIPART_FORM_DATA.
* Produces a JSON respomse
*
* @param parts a flux providing all part contained in the MULTIPART_FORM_DATA request
import java.util.Calendar;
import java.util.function.Consumer;
/**
* Created by emilkirschner on 13/02/17.
*/
class BaseBenchmarkState {
protected void generateTime(Consumer<Long> consumer) {
for (int month = Calendar.JANUARY; month <= Calendar.DECEMBER; month++) {
for (int day = 0; day <= 28; day++) {
@entzik
entzik / EnvObsTimeSeries.java
Last active January 3, 2020 06:57
EnvObsTimeSeries.java
package com.thekirschners.emplacements.column;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Spliterator;
import java.util.Spliterators;
import java.util.function.Consumer;
import java.util.stream.DoubleStream;
import java.util.stream.LongStream;
import java.util.stream.Stream;