This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
EXOGRAPH_DB_USER=<<dummy>>_user | |
EXOGRAPH_DB_PASSWORD=<<dummy>>_password | |
EXOGRAPH_DB=<<dummy>>_db | |
EXO_POSTGRES_URL=postgresql://$EXOGRAPH_DB_USER:$EXOGRAPH_DB_PASSWORD@localhost:5432/$EXOGRAPH_DB | |
EXO_CORS_DOMAINS="*" | |
# Use `openssl rand -base64 32` to generate a key | |
EXO_JWT_SECRET=<<some_secret>> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
version: '3.7' | |
services: | |
redpanda: | |
image: docker.vectorized.io/vectorized/redpanda:v22.1.7 | |
container_name: redpanda | |
hostname: redpanda | |
command: | |
- redpanda start | |
- --overprovisioned | |
- --smp 1 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
def make_date_file_sensor_for_asset(j: JobDefinition, resource_defs_for_ssh): | |
@sensor( | |
job=j, | |
name=j.name + "_sensor", | |
default_status=DefaultSensorStatus.RUNNING, | |
) | |
def date_file_sensor(context): | |
with build_resources(resource_defs_for_ssh) as resources: | |
ssh = resources.ssh | |
sftp = ssh.open_sftp() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
version: '3.7' | |
# based on | |
# 1. https://redpandacommunity.slack.com/archives/C01AJDUT88N/p1657529113002319?thread_ts=1657527079.070669&cid=C01AJDUT88N | |
# 2. https://redpandacommunity.slack.com/archives/C01AJDUT88N/p1652213796745369?thread_ts=1652195821.668589&cid=C01AJDUT88N | |
services: | |
redpanda: | |
image: docker.vectorized.io/vectorized/redpanda:v22.1.4 | |
container_name: redpanda | |
hostname: redpanda | |
command: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
``` | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function geospark_rs_array replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function geospark_rs_normalize replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function geospark_st_union_aggr replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function geospark_st_envelope_aggr replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function geospark_st_intersection_aggr replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function st_boundary replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function st_coorddim replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionRegistry: The function st_dimension replaced a previously registered function. | |
22/02/10 17:07:54 WARN SimpleFunctionReg |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
sure: | |
%pylab inline | |
import stumpy | |
import pandas as pd | |
import numpy as np | |
import random | |
random_seed = 47 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
df['device_id'] = df['device_id'].astype(str).apply(lambda x: x.zfill(2)) | |
df = df.sort_values(['device_id']) | |
d_r = df.reset_index() | |
a4_dims = (11.7, 8.27) | |
fig, ax = pyplot.subplots(figsize=a4_dims) | |
ax = sns.lineplot(x='index', y='metrik_0', style='device_id', hue='device_id', data=d_r, ax=ax) | |
import matplotlib.dates as mdates | |
ax.axvspan(*mdates.datestr2num(['2020-01-04 05:00:00', '2020-01-05 16:00:00']), color='gray', alpha=0.2) | |
ax.axvspan(*mdates.datestr2num(['2020-01-04 15:00:00', '2020-01-05 00:00:00']), color='gray', alpha=0.2) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# packages in environment at ~/.conda/envs/rapidstest: | |
# | |
# Name Version Build Channel | |
_libgcc_mutex 0.1 conda_forge /conda-forge | |
_openmp_mutex 4.5 1_gnu /conda-forge | |
abseil-cpp 20200225.2 he1b5a44_2 /conda-forge | |
aiohttp 3.6.2 py38h516909a_0 /conda-forge | |
appdirs 1.4.3 py_1 /conda-forge | |
argon2-cffi 20.1.0 py38h1e0a361_1 /conda-forge | |
arrow-cpp 0.17.1 py38h1234567_11_cpu /conda-forge |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
``` | |
(rapidstest) > $ conda list [±4-econ-graph ●●] | |
# packages in environment at ~/.conda/envs/rapidstest: | |
# | |
# Name Version Build Channel | |
_libgcc_mutex 0.1 conda_forge /conda-forge | |
_openmp_mutex 4.5 1_gnu /conda-forge | |
aiohttp 3.6.2 py37h516909a_0 /conda-forge | |
appdirs 1.4.3 py_1 /conda-forge |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// setup in bash | |
wget https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka_2.11/1.11.1/flink-connector-kafka_2.11-1.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka-base_2.11/1.11.1/flink-connector-kafka-base_2.11-1.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/kafka/kafka-clients/0.10.2.1/kafka-clients-0.10.2.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/flink/flink-avro-confluent-registry/1.11.1/flink-avro-confluent-registry-1.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/flink/flink-avro/1.11.1/flink-avro-1.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/flink/force-shading/1.11.1/force-shading-1.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/org/apache/avro/avro/1.8.2/avro-1.8.2.jar -P lib/ | |
wget https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-core/2.11.1/jackson-core-2.11.1.jar -P lib/ | |
wget https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-d |
NewerOlder