Проверка папки на появление новых файлов

[dominic]

Доброго времени суток.
Подскажите, пожалуйста, куда копать или ткните носом в мануал.

Есть некое приложение, которое генерирует отчеты в csv по расписанию (ежедневный, еженедельный, ежемесячный).
Отчеты сохраняются в определенной папке.
Необходимо:
1) чтобы некий скрипт следил за папкой и при ее обновлении (т.е. когда в ней появляется новый файл) или по расписанию сигнализировал о появлении новых csv, чтобы....
2) данные из csv импортировались в базу MySQL.
3) исходный файл удалялся или переносился в папку для бэкапов (на всякий случай ).

Все это нужно, чтобы пользователи сайта могли видеть в удобоваримом виде эти самые данные из csv.

Заранее спасибо.

[shumtest]

Можно, конечно, и мониторинг на папку повесить, но с учетом не частого появления отчетов (ежедневный самое частое?) проще скриптик в крон поставить на раз в час, вот он пусть все и делает.

[Yurror]

(Нажмите, чтобы показать/скрыть)

Код: [Выделить]

#include <unistd.h>
#include <sys/select.h>
#include <sys/inotify.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/ioctl.h>
#include <ftw.h>
#include <stdio.h>
#include <stdlib.h>
#include <map>
#include <string>

#define WATCHED_EVENTS (IN_ATTRIB | IN_CREATE | IN_DELETE | IN_MODIFY)

static int in_fd;
static const char *base_path;
static std::map<int, std::string> watch_dirs;

static int ftw_callback(const char *path, const struct stat *st, int type)
{
    if (type == FTW_D)
    {
        int wd = inotify_add_watch(in_fd, path, WATCHED_EVENTS);
        if (wd < 0)
        {
            perror("inotify_add_watch");
            return 1;
        }
        watch_dirs[wd] = path;
    }
    return 0;
}

static int watch_dir_rec(const char *path)
{
    in_fd = inotify_init();
    if (in_fd < 0)
    {
        perror("inotify_init");
        return -1;
    }
    base_path = path;
    if (ftw(path, ftw_callback, 10))
    {
        perror("ftw");
        close(in_fd);
        return -1;
    }
    return in_fd;
}

static void print_event(const struct inotify_event *event)
{
    int out = 0;
    printf("%s/%s: ", watch_dirs[event->wd].c_str(), event->name);
    #define mask(evt) if (event->mask & evt) { \
        printf(out ? " | %s" : "%s", #evt); \
        out = 1; \
    }
    mask(IN_ACCESS);
    mask(IN_ATTRIB);
    mask(IN_CLOSE_WRITE);
    mask(IN_CLOSE_NOWRITE);
    mask(IN_CREATE);
    mask(IN_DELETE);
    mask(IN_DELETE_SELF);
    mask(IN_MODIFY);
    mask(IN_MOVE_SELF);
    mask(IN_MOVED_FROM);
    mask(IN_MOVED_TO);
    mask(IN_OPEN);
    #undef mask
    fputc('\n', stdout);
    fflush(stdout);
}

static void watch_loop(int fd)
{
    fd_set fds;
    FD_ZERO(&fds);
    FD_SET(fd, &fds);
    while (select(fd + 1, &fds, NULL, NULL, NULL) >= 0)
    {
        if (FD_ISSET(fd, &fds))
        {
            int bytes_avail;
            char *buf;
            struct inotify_event *event;
            if (ioctl(fd, FIONREAD, &bytes_avail) < 0)
            {
                perror("ioctl");
                break;
            }
            buf = (char*)malloc(bytes_avail);
            if (!buf)
            {
                abort();
            }
            event = (struct inotify_event*)buf;
            if (read(fd, buf, bytes_avail) > 0)
            {
                int offset = 0;
                while (offset < bytes_avail)
                {
                    event = (struct inotify_event*)&buf[offset];
                    offset += (sizeof(struct inotify_event) + event->len);
                    print_event(event);
                }
            }
            else
            {
                perror("read");
            }
            free(buf);
        }
        FD_ZERO(&fds);
        FD_SET(fd, &fds);
    }
    perror("select");
}

int main(int argc, char **argv)
{
    int fd;
    if (argc < 2)
    {
        fprintf(stderr, "Usage:\n%s <directory to watch>\n", argv[0]);
        return 1;
    }
    fd = watch_dir_rec(argv[1]);
    if (fd < 0)
    {
        return 1;
    }
    watch_loop(fd);
    close(fd);
    return 0;
}



Нашел в закромах родины

[Mam(O)n]

incron - это то, что в данном случае нужно.

[xkool]

incron статья на Хабре

[Yurror]

козырно, не знал =)