Skip to content

Instantly share code, notes, and snippets.

View ehlyzov's full-sized avatar

Eugene Hlyzov ehlyzov

30 followers · 12 following
  • http://datafabric.cc
  • SaintPetersburg, Russia
View GitHub Profile
@ehlyzov
ehlyzov / gist:8b69ddf409f7534592c9c6de5302cd7a
Created July 16, 2020 11:56
InfoexchangeTest.kt
package cc.datafabric.infoexchange.streams.gate;
import com.salesforce.kafka.test.junit5.SharedKafkaTestResource;
import de.bwaldvogel.mongo.MongoServer;
import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;
import java.net.InetSocketAddress;
@ehlyzov
ehlyzov / grep_by_okved_postcode.sparql
Last active November 19, 2017 12:42
PREFIX fts: <https://w3id.org/datafabric.cc/ontologies/fts#>
SELECT ?ogrn ?primaryCode ?fullname WHERE {
?leUri a fts:C101_Russian_Legal_Entity .
?addressE a fts:C39_Address_Entity ;
fts:p82_refers_to_company ?leUri ;
fts:isLatestEntity "true"^^xsd:boolean ;
fts:p18_postcode "193231" .
@ehlyzov
ehlyzov / demo.py
Last active January 20, 2018 12:03 — forked from KMax/gist:fe24c9fffa58af7e116bd254e6330b99
Rosstat Stats from Datafabric.cc
##
## Возвращает список учредителей ООО ДатаФабрик
##
from SPARQLWrapper import SPARQLWrapper, JSON
sparql = SPARQLWrapper("http://104.155.96.199/blazegraph/sparql")
sparql.setQuery("""
PREFIX fts: <https://w3id.org/datafabric.cc/ontologies/fts#>
@ehlyzov
ehlyzov / fizzbuzz.js
Created July 17, 2016 12:59
FizzBuzz based on nools.js
'use strict';
const nl = require('nools');
class Message {
constructor() {
this.text = '';
}
@ehlyzov
ehlyzov / queue.js
Last active June 30, 2016 05:19
Bulk copy script
'use strict';
var Queue = require('bull'),
path = require('path'),
fs = require('fs'),
_ = require('lodash')
if (process.argv.length <= 2) {
console.log("Usage: " + __filename + " path/to/directory");
process.exit(1);
@ehlyzov
ehlyzov / df.entity.js
Last active April 21, 2016 12:56
Example
(function (data) {
env.async.waterfall([
env.async.apply(
env.model[data.model].findOne,
env.lodash.defaults(data.findParams || {}, {
name: data.name,
value: data.payload.value
})),
function(found, next) {
if (found) {
@ehlyzov
ehlyzov / README
Created September 23, 2015 14:17 — forked from nelix/README
Cloud66 postgresql with wal backups on S3
You need to do base backups often...
sudo -u postgres envdir /etc/wal-e.d/env /usr/local/bin/wal-e backup-push /usr/local/pgsql/data
You can check how many objects are not archived:
./var/backup_status.sh
@ehlyzov
ehlyzov / gist:4e1d77150fe1e6592749
Created September 23, 2015 14:15 — forked from sandsu/gist:2aeab3e71100d58e48b7
WAL-E and Cloud66
# WAL-E (https://github.com/wal-e/wal-e) install
sudo su
source /var/.cloud66_env
sudo apt-get install daemontools
sudo apt-get install -y python-virtualenv python-dev git libevent-dev pv lzop vim
sudo pip install git+https://github.com/wal-e/wal-e
umask u=rwx,g=rx,o=
mkdir -p /etc/wal-e.d/env
echo $AWS_SECRET_ACCESS_KEY > /etc/wal-e.d/env/AWS_SECRET_ACCESS_KEY
@ehlyzov
ehlyzov / base.rb
Created July 20, 2015 15:29
def available_awards
# не даем, если награда уникальна и уже выдана
return [] if @award.unique? && award_exists?
# не даем, если пользователь не подходит по группе
return [] if (@award.for_group? == false) ||
(@award.group_ids & @user.group_memberships.pluck(:group_id)).any?
# не даем, если награда дневная и она уже была выдана
return [] if (@award.main_slot? || @award.bonus_slot?) && (day_count == 0)
@ehlyzov
ehlyzov / dump_mongo.py
Created May 13, 2015 19:55
from mongo import *
from api.maps import *
from api.poster import *
import json as simple_json
from bson import json_util
from datetime import datetime
def json_serial(obj):
if isinstance(obj, datetime):